diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/AccountRoutingUpdate.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/AccountRoutingHistory.java similarity index 89% rename from clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/AccountRoutingUpdate.java rename to clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/AccountRoutingHistory.java index 52906036a..1c4dc5c8e 100644 --- a/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/AccountRoutingUpdate.java +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/AccountRoutingHistory.java @@ -8,7 +8,7 @@ import java.io.Serial; * * DB table: ACCOUNT_ROUTING_UPDATE **/ -public class AccountRoutingUpdate extends BusinessEvent { +public class AccountRoutingHistory extends BusinessEvent { @Serial private static final long serialVersionUID = ConstSerializable.serialVersionUID; diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/BankAccountUpdate.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/BankAccountHistory.java similarity index 90% rename from clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/BankAccountUpdate.java rename to clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/BankAccountHistory.java index 6e2323b7c..35cc0adbf 100644 --- a/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/BankAccountUpdate.java +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/BankAccountHistory.java @@ -7,7 +7,7 @@ import java.io.Serial; * * DB table: BANK_ACCOUNT_UPDATE **/ -public class BankAccountUpdate extends BusinessEvent { +public class BankAccountHistory extends BusinessEvent { @Serial private static final long serialVersionUID = ConstSerializable.serialVersionUID; diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/ClearingAccountUpdate.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/ClearingAccountHistory.java similarity index 89% rename from clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/ClearingAccountUpdate.java rename to clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/ClearingAccountHistory.java index b1c4eb8c8..70a8f92a8 100644 --- a/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/ClearingAccountUpdate.java +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/ClearingAccountHistory.java @@ -8,7 +8,7 @@ import java.io.Serial; * * DB table: CLEARING_ACCOUNT_UPDATE **/ -public class ClearingAccountUpdate extends BusinessEvent { +public class ClearingAccountHistory extends BusinessEvent { @Serial private static final long serialVersionUID = ConstSerializable.serialVersionUID; diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/InformationAccount.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/InformationAccount.java index 0bd1a3ab2..46ba06ce7 100644 --- a/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/InformationAccount.java +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/InformationAccount.java @@ -10,7 +10,6 @@ import ru.spcex.platform.classes.base.SpcexObjectBase; public class InformationAccount extends SpcexObjectBase { private static final long serialVersionUID = ConstSerializable.serialVersionUID; - // (in parent) private Long id; private Long accountId; private String account; private Long clearingAccountId; diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/InformationAccountUpdate.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/InformationAccountHistory.java similarity index 88% rename from clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/InformationAccountUpdate.java rename to clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/InformationAccountHistory.java index 16503cb1a..fa79beb75 100644 --- a/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/InformationAccountUpdate.java +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/StaticData/Account/InformationAccountHistory.java @@ -8,7 +8,7 @@ import java.io.Serial; * * DB table: INFORMATION_ACCOUNT_UPDATE **/ -public class InformationAccountUpdate extends BusinessEvent { +public class InformationAccountHistory extends BusinessEvent { @Serial private static final long serialVersionUID = ConstSerializable.serialVersionUID; diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/messages/ErrorText.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/messages/ErrorText.java new file mode 100644 index 000000000..554e6ba41 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/messages/ErrorText.java @@ -0,0 +1,53 @@ +package ru.clearing.classes.statics.data.messages; + +import ru.clearing.classes.ConstSerializable; +import ru.spcex.platform.classes.base.SpcexObjectBase; + +import java.time.Instant; + +/** + * Полные тексты ошибок + *

+ * DB table: ERROR_TEXT + **/ +public class ErrorText extends BusinessBase { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private String errorCode; + private String text; + private Long userId; + private Instant clearingDate; + + public String getErrorCode() { + return errorCode; + } + + public void setErrorCode(String value) { + this.errorCode = value; + } + + public String getText() { + return text; + } + + public void setText(String value) { + this.text = value; + } + + public Long getUserId() { + return userId; + } + + public void setUserId(Long value) { + this.userId = value; + } + + public Instant getClearingDate() { + return clearingDate; + } + + public void setClearingDate(Instant value) { + this.clearingDate = value; + } + +} diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/RequestDf03.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/RequestDf03.java new file mode 100644 index 000000000..4afb2c2bf --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/RequestDf03.java @@ -0,0 +1,409 @@ +package ru.clearing.classes.statics.data.sdf; + +import ru.clearing.classes.ConstSerializable; +import ru.spcex.platform.classes.base.SpcexObjectBase; + +import java.time.Instant; + +/** + * Платежное поручение + * + * DB table: REQUEST_DF03 + **/ +public class RequestDf03 extends SpcexObjectBase { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private Instant requestDate; + private Instant responseDate; + private String docType; + private String docnmRef; + private String docnmprev; + private String priority; + private String sbankcode; + private String cAccDeb; + private String sbanknam1; + private String sbanknam2; + private String sbanknam3; + private String sbanknam4; + private String sbanknam5; + private String rbankcode; + private String cAccCred; + private String rbanknam1; + private String rbanknam2; + private String rbanknam3; + private String rbanknam4; + private String rbanknam5; + private Instant payDate; + private String extDate; + private String payVal; + private BigDecimal sumDeb; + private String sclientn1; + private String sclientn2; + private String sclientn3; + private String sclientn4; + private String scCode; + private String accDeb; + private String rclientn1; + private String rclientn2; + private String rclientn3; + private String rclientn4; + private String accKr_1; + private String accKr_2; + private String spCode; + private String specif_1; + private String specif_2; + private String specif_3; + private String specif_4; + private String specif_5; + private String specif_6; + private String sendType; + private String servdate; + private String docResult; + private String sendResult; + private String errorText; + private String responseResult; + + public Instant getRequestDate() { + return requestDate; + } + public void setRequestDate(Instant value) { + this.requestDate=value; + } + + public Instant getResponseDate() { + return responseDate; + } + public void setResponseDate(Instant value) { + this.responseDate=value; + } + + public String getDocType() { + return docType; + } + public void setDocType(String value) { + this.docType=value; + } + + public String getDocnmRef() { + return docnmRef; + } + public void setDocnmRef(String value) { + this.docnmRef=value; + } + + public String getDocnmprev() { + return docnmprev; + } + public void setDocnmprev(String value) { + this.docnmprev=value; + } + + public String getPriority() { + return priority; + } + public void setPriority(String value) { + this.priority=value; + } + + public String getSbankcode() { + return sbankcode; + } + public void setSbankcode(String value) { + this.sbankcode=value; + } + + public String getCAccDeb() { + return cAccDeb; + } + public void setCAccDeb(String value) { + this.cAccDeb=value; + } + + public String getSbanknam1() { + return sbanknam1; + } + public void setSbanknam1(String value) { + this.sbanknam1=value; + } + + public String getSbanknam2() { + return sbanknam2; + } + public void setSbanknam2(String value) { + this.sbanknam2=value; + } + + public String getSbanknam3() { + return sbanknam3; + } + public void setSbanknam3(String value) { + this.sbanknam3=value; + } + + public String getSbanknam4() { + return sbanknam4; + } + public void setSbanknam4(String value) { + this.sbanknam4=value; + } + + public String getSbanknam5() { + return sbanknam5; + } + public void setSbanknam5(String value) { + this.sbanknam5=value; + } + + public String getRbankcode() { + return rbankcode; + } + public void setRbankcode(String value) { + this.rbankcode=value; + } + + public String getCAccCred() { + return cAccCred; + } + public void setCAccCred(String value) { + this.cAccCred=value; + } + + public String getRbanknam1() { + return rbanknam1; + } + public void setRbanknam1(String value) { + this.rbanknam1=value; + } + + public String getRbanknam2() { + return rbanknam2; + } + public void setRbanknam2(String value) { + this.rbanknam2=value; + } + + public String getRbanknam3() { + return rbanknam3; + } + public void setRbanknam3(String value) { + this.rbanknam3=value; + } + + public String getRbanknam4() { + return rbanknam4; + } + public void setRbanknam4(String value) { + this.rbanknam4=value; + } + + public String getRbanknam5() { + return rbanknam5; + } + public void setRbanknam5(String value) { + this.rbanknam5=value; + } + + public Instant getPayDate() { + return payDate; + } + public void setPayDate(Instant value) { + this.payDate=value; + } + + public String getExtDate() { + return extDate; + } + public void setExtDate(String value) { + this.extDate=value; + } + + public String getPayVal() { + return payVal; + } + public void setPayVal(String value) { + this.payVal=value; + } + + public BigDecimal getSumDeb() { + return sumDeb; + } + public void setSumDeb(BigDecimal value) { + this.sumDeb=value; + } + + public String getSclientn1() { + return sclientn1; + } + public void setSclientn1(String value) { + this.sclientn1=value; + } + + public String getSclientn2() { + return sclientn2; + } + public void setSclientn2(String value) { + this.sclientn2=value; + } + + public String getSclientn3() { + return sclientn3; + } + public void setSclientn3(String value) { + this.sclientn3=value; + } + + public String getSclientn4() { + return sclientn4; + } + public void setSclientn4(String value) { + this.sclientn4=value; + } + + public String getScCode() { + return scCode; + } + public void setScCode(String value) { + this.scCode=value; + } + + public String getAccDeb() { + return accDeb; + } + public void setAccDeb(String value) { + this.accDeb=value; + } + + public String getRclientn1() { + return rclientn1; + } + public void setRclientn1(String value) { + this.rclientn1=value; + } + + public String getRclientn2() { + return rclientn2; + } + public void setRclientn2(String value) { + this.rclientn2=value; + } + + public String getRclientn3() { + return rclientn3; + } + public void setRclientn3(String value) { + this.rclientn3=value; + } + + public String getRclientn4() { + return rclientn4; + } + public void setRclientn4(String value) { + this.rclientn4=value; + } + + public String getAccKr_1() { + return accKr_1; + } + public void setAccKr_1(String value) { + this.accKr_1=value; + } + + public String getAccKr_2() { + return accKr_2; + } + public void setAccKr_2(String value) { + this.accKr_2=value; + } + + public String getSpCode() { + return spCode; + } + public void setSpCode(String value) { + this.spCode=value; + } + + public String getSpecif_1() { + return specif_1; + } + public void setSpecif_1(String value) { + this.specif_1=value; + } + + public String getSpecif_2() { + return specif_2; + } + public void setSpecif_2(String value) { + this.specif_2=value; + } + + public String getSpecif_3() { + return specif_3; + } + public void setSpecif_3(String value) { + this.specif_3=value; + } + + public String getSpecif_4() { + return specif_4; + } + public void setSpecif_4(String value) { + this.specif_4=value; + } + + public String getSpecif_5() { + return specif_5; + } + public void setSpecif_5(String value) { + this.specif_5=value; + } + + public String getSpecif_6() { + return specif_6; + } + public void setSpecif_6(String value) { + this.specif_6=value; + } + + public String getSendType() { + return sendType; + } + public void setSendType(String value) { + this.sendType=value; + } + + public String getServdate() { + return servdate; + } + public void setServdate(String value) { + this.servdate=value; + } + + public String getDocResult() { + return docResult; + } + public void setDocResult(String value) { + this.docResult=value; + } + + public String getSendResult() { + return sendResult; + } + public void setSendResult(String value) { + this.sendResult=value; + } + + public String getErrorText() { + return errorText; + } + public void setErrorText(String value) { + this.errorText=value; + } + + public String getResponseResult() { + return responseResult; + } + public void setResponseResult(String value) { + this.responseResult=value; + } + +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/RequestDf05.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/RequestDf05.java new file mode 100644 index 000000000..7d1afd03f --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/RequestDf05.java @@ -0,0 +1,81 @@ +package ru.clearing.classes.statics.data.sdf; + +import ru.clearing.classes.ConstSerializable; +import ru.spcex.platform.classes.base.SpcexObjectBase; + +import java.math.BigDecimal; +import java.time.Instant; + +/** + * ДФ 05 - Уведомление о завершении расчетов в ПРЦ + *

+ * DB table: REQUEST_DF05 + **/ +public class RequestDf05 extends SpcexObjectBase { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private BigDecimal tp; + private Instant dt; + private Instant tm; + private String pr; + private String fileName; + private Instant generationTime; + private Long generationId; + + public BigDecimal getTp() { + return tp; + } + + public void setTp(BigDecimal value) { + this.tp = value; + } + + public Instant getDt() { + return dt; + } + + public void setDt(Instant value) { + this.dt = value; + } + + public Instant getTm() { + return tm; + } + + public void setTm(Instant value) { + this.tm = value; + } + + public String getPr() { + return pr; + } + + public void setPr(String value) { + this.pr = value; + } + + public String getFileName() { + return fileName; + } + + public void setFileName(String value) { + this.fileName = value; + } + + public Instant getGenerationTime() { + return generationTime; + } + + public void setGenerationTime(Instant value) { + this.generationTime = value; + } + + public Long getGenerationId() { + return generationId; + } + + public void setGenerationId(Long value) { + this.generationId = value; + } + +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/RequestDf18.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/RequestDf18.java new file mode 100644 index 000000000..7e2390073 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/RequestDf18.java @@ -0,0 +1,90 @@ +package ru.clearing.classes.statics.data.sdf; + +import ru.clearing.classes.ConstSerializable; +import ru.spcex.platform.classes.base.SpcexObjectBase; + +import java.math.BigDecimal; +import java.time.Instant; + +/** + * ДФ18 – Запрос остатков по всем счетам + *

+ * DB table: REQUEST_DF18 + **/ +public class RequestDf18 extends SpcexObjectBase { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private Instant datetime; + private String account; + private String deal; + private BigDecimal status; + private BigDecimal result; + private String fileName; + private Instant generationTime; + private Long generationId; + + public Instant getDatetime() { + return datetime; + } + + public void setDatetime(Instant value) { + this.datetime = value; + } + + public String getAccount() { + return account; + } + + public void setAccount(String value) { + this.account = value; + } + + public String getDeal() { + return deal; + } + + public void setDeal(String value) { + this.deal = value; + } + + public BigDecimal getStatus() { + return status; + } + + public void setStatus(BigDecimal value) { + this.status = value; + } + + public BigDecimal getResult() { + return result; + } + + public void setResult(BigDecimal value) { + this.result = value; + } + + public String getFileName() { + return fileName; + } + + public void setFileName(String value) { + this.fileName = value; + } + + public Instant getGenerationTime() { + return generationTime; + } + + public void setGenerationTime(Instant value) { + this.generationTime = value; + } + + public Long getGenerationId() { + return generationId; + } + + public void setGenerationId(Long value) { + this.generationId = value; + } + +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf01.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf01.java new file mode 100644 index 000000000..6bfcc9f20 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf01.java @@ -0,0 +1,152 @@ +package ru.clearing.classes.statics.data.sdf; + +import ru.clearing.classes.ConstSerializable; +import ru.spcex.platform.classes.base.SpcexObjectBase; + +import java.time.Instant; + +/** + * ДФ-01 Информация о денежных средствах, находящихся на торговых банковских счетах Участников клиринга + *

+ * DB table: S_DF01 + **/ +public class SDf01 extends SpcexObjectBase { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private String curr_code; + private String account; + private String remainder; + private String deal; + private String acc_code; + private String dat; + private String market; + private String acc_name; + private String acc_type; + private String sumengage; + private String sumunblock; + private String file_type; + private String fileName; + private Instant generationTime; + private Long generationId; + + public String getCurr_code() { + return curr_code; + } + + public void setCurr_code(String value) { + this.curr_code = value; + } + + public String getAccount() { + return account; + } + + public void setAccount(String value) { + this.account = value; + } + + public String getRemainder() { + return remainder; + } + + public void setRemainder(String value) { + this.remainder = value; + } + + public String getDeal() { + return deal; + } + + public void setDeal(String value) { + this.deal = value; + } + + public String getAcc_code() { + return acc_code; + } + + public void setAcc_code(String value) { + this.acc_code = value; + } + + public String getDat() { + return dat; + } + + public void setDat(String value) { + this.dat = value; + } + + public String getMarket() { + return market; + } + + public void setMarket(String value) { + this.market = value; + } + + public String getAcc_name() { + return acc_name; + } + + public void setAcc_name(String value) { + this.acc_name = value; + } + + public String getAcc_type() { + return acc_type; + } + + public void setAcc_type(String value) { + this.acc_type = value; + } + + public String getSumengage() { + return sumengage; + } + + public void setSumengage(String value) { + this.sumengage = value; + } + + public String getSumunblock() { + return sumunblock; + } + + public void setSumunblock(String value) { + this.sumunblock = value; + } + + public String getFile_type() { + return file_type; + } + + public void setFile_type(String value) { + this.file_type = value; + } + + public String getFileName() { + return fileName; + } + + public void setFileName(String value) { + this.fileName = value; + } + + public Instant getGenerationTime() { + return generationTime; + } + + public void setGenerationTime(Instant value) { + this.generationTime = value; + } + + public Long getGenerationId() { + return generationId; + } + + public void setGenerationId(Long value) { + this.generationId = value; + } + +} diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf02.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf02.java new file mode 100644 index 000000000..6a4030761 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf02.java @@ -0,0 +1,161 @@ +package ru.clearing.classes.statics.data.sdf; + +import ru.clearing.classes.ConstSerializable; +import ru.spcex.platform.classes.base.SpcexObjectBase; + +import java.time.Instant; + +/** + * ДФ-02 Уведомление об исполнении операции загрузки денежных средств или уведомление об ошибке + *

+ * DB table: S_DF02 + **/ +public class SDf02 extends SpcexObjectBase { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private String curr_code; + private String account; + private String remainder; + private String deal; + private String acc_code; + private String dat; + private String market; + private String acc_name; + private String acc_type; + private String sumengage; + private String sumunblock; + private String file_type; + private String result; + private String fileName; + private Instant generationTime; + private Long generationId; + + public String getCurr_code() { + return curr_code; + } + + public void setCurr_code(String value) { + this.curr_code = value; + } + + public String getAccount() { + return account; + } + + public void setAccount(String value) { + this.account = value; + } + + public String getRemainder() { + return remainder; + } + + public void setRemainder(String value) { + this.remainder = value; + } + + public String getDeal() { + return deal; + } + + public void setDeal(String value) { + this.deal = value; + } + + public String getAcc_code() { + return acc_code; + } + + public void setAcc_code(String value) { + this.acc_code = value; + } + + public String getDat() { + return dat; + } + + public void setDat(String value) { + this.dat = value; + } + + public String getMarket() { + return market; + } + + public void setMarket(String value) { + this.market = value; + } + + public String getAcc_name() { + return acc_name; + } + + public void setAcc_name(String value) { + this.acc_name = value; + } + + public String getAcc_type() { + return acc_type; + } + + public void setAcc_type(String value) { + this.acc_type = value; + } + + public String getSumengage() { + return sumengage; + } + + public void setSumengage(String value) { + this.sumengage = value; + } + + public String getSumunblock() { + return sumunblock; + } + + public void setSumunblock(String value) { + this.sumunblock = value; + } + + public String getFile_type() { + return file_type; + } + + public void setFile_type(String value) { + this.file_type = value; + } + + public String getResult() { + return result; + } + + public void setResult(String value) { + this.result = value; + } + + public String getFileName() { + return fileName; + } + + public void setFileName(String value) { + this.fileName = value; + } + + public Instant getGenerationTime() { + return generationTime; + } + + public void setGenerationTime(Instant value) { + this.generationTime = value; + } + + public Long getGenerationId() { + return generationId; + } + + public void setGenerationId(Long value) { + this.generationId = value; + } + +} diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf08.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf08.java new file mode 100644 index 000000000..d77d09890 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf08.java @@ -0,0 +1,63 @@ +package ru.clearing.classes.statics.data.sdf; + +import ru.clearing.classes.ConstSerializable; +import ru.spcex.platform.classes.base.SpcexObjectBase; + +import java.math.BigDecimal; +import java.time.Instant; + +/** + * ДФ-08 Запрос остатков по всем счетам + *

+ * DB table: S_DF08 + **/ +public class SDf08 extends SpcexObjectBase { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private BigDecimal number; + private BigDecimal datetime; + private String fileName; + private Instant generationTime; + private Long generationId; + + public BigDecimal getNumber() { + return number; + } + + public void setNumber(BigDecimal value) { + this.number = value; + } + + public BigDecimal getDatetime() { + return datetime; + } + + public void setDatetime(BigDecimal value) { + this.datetime = value; + } + + public String getFileName() { + return fileName; + } + + public void setFileName(String value) { + this.fileName = value; + } + + public Instant getGenerationTime() { + return generationTime; + } + + public void setGenerationTime(Instant value) { + this.generationTime = value; + } + + public Long getGenerationId() { + return generationId; + } + + public void setGenerationId(Long value) { + this.generationId = value; + } + +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf16.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf16.java new file mode 100644 index 000000000..e1c291584 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/sdf/SDf16.java @@ -0,0 +1,135 @@ +package ru.clearing.classes.statics.data.sdf; + +import ru.clearing.classes.ConstSerializable; +import ru.spcex.platform.classes.base.SpcexObjectBase; + +import java.math.BigDecimal; +import java.time.Instant; + +/** + * ДФ 16 - Ответ КС на запрос на дозачисление/списание денежных средств + *

+ * DB table: S_DF16 + **/ +public class SDf16 extends SpcexObjectBase { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private Instant date; + private String account; + private BigDecimal sum; + private String market; + private String type; + private BigDecimal INN; + private BigDecimal BIC; + private String SPEC; + private BigDecimal number; + private String resultCode; + private String fileName; + private Instant generationTime; + private Long generationId; + + public Instant getDate() { + return date; + } + + public void setDate(Instant value) { + this.date = value; + } + + public String getAccount() { + return account; + } + + public void setAccount(String value) { + this.account = value; + } + + public BigDecimal getSum() { + return sum; + } + + public void setSum(BigDecimal value) { + this.sum = value; + } + + public String getMarket() { + return market; + } + + public void setMarket(String value) { + this.market = value; + } + + public String getType() { + return type; + } + + public void setType(String value) { + this.type = value; + } + + public BigDecimal getINN() { + return INN; + } + + public void setINN(BigDecimal value) { + this.INN = value; + } + + public BigDecimal getBIC() { + return BIC; + } + + public void setBIC(BigDecimal value) { + this.BIC = value; + } + + public String getSPEC() { + return SPEC; + } + + public void setSPEC(String value) { + this.SPEC = value; + } + + public BigDecimal getNumber() { + return number; + } + + public void setNumber(BigDecimal value) { + this.number = value; + } + + public String getResultCode() { + return resultCode; + } + + public void setResultCode(String value) { + this.resultCode = value; + } + + public String getFileName() { + return fileName; + } + + public void setFileName(String value) { + this.fileName = value; + } + + public Instant getGenerationTime() { + return generationTime; + } + + public void setGenerationTime(Instant value) { + this.generationTime = value; + } + + public Long getGenerationId() { + return generationId; + } + + public void setGenerationId(Long value) { + this.generationId = value; + } + +} \ No newline at end of file diff --git a/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/statement/Statement.java b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/statement/Statement.java new file mode 100644 index 000000000..038045266 --- /dev/null +++ b/clearing-parent/classes/src/main/java/ru/clearing/classes/statics/data/statement/Statement.java @@ -0,0 +1,162 @@ +package ru.clearing.classes.statics.data.statement; + +import ru.clearing.classes.ConstSerializable; +import ru.spcex.platform.classes.base.BusinessObject; + +import java.math.BigDecimal; +import java.time.Instant; + +/** + * Денежные средства от расчетной организации + *

+ * DB table: STATEMENT + **/ +public class Statement extends BusinessObject { + private static final long serialVersionUID = ConstSerializable.serialVersionUID; + + private Long addresseeId; + private Long senderId; + private Instant clearingDate; + private Long statementTypeId; + private String comment; + private Long accountId; + private Long account; + private Long inOutDirection; + private Instant settlementDate; + private BigDecimal amount; + private String cashMovementCurrencyCode; + private String status; + private String errorCode; + private String errorText; + private Long inSDfId; + private Long outSDfId; + + public Long getAddresseeId() { + return addresseeId; + } + + public void setAddresseeId(Long value) { + this.addresseeId = value; + } + + public Long getSenderId() { + return senderId; + } + + public void setSenderId(Long value) { + this.senderId = value; + } + + public Instant getClearingDate() { + return clearingDate; + } + + public void setClearingDate(Instant value) { + this.clearingDate = value; + } + + public Long getStatementTypeId() { + return statementTypeId; + } + + public void setStatementTypeId(Long value) { + this.statementTypeId = value; + } + + public String getComment() { + return comment; + } + + public void setComment(String value) { + this.comment = value; + } + + public Long getAccountId() { + return accountId; + } + + public void setAccountId(Long value) { + this.accountId = value; + } + + public Long getAccount() { + return account; + } + + public void setAccount(Long value) { + this.account = value; + } + + public Long getInOutDirection() { + return inOutDirection; + } + + public void setInOutDirection(Long value) { + this.inOutDirection = value; + } + + public Instant getSettlementDate() { + return settlementDate; + } + + public void setSettlementDate(Instant value) { + this.settlementDate = value; + } + + public BigDecimal getAmount() { + return amount; + } + + public void setAmount(BigDecimal value) { + this.amount = value; + } + + public String getCashMovementCurrencyCode() { + return cashMovementCurrencyCode; + } + + public void setCashMovementCurrencyCode(String value) { + this.cashMovementCurrencyCode = value; + } + + public String getStatus() { + return status; + } + + public void setStatus(String value) { + this.status = value; + } + + public String getErrorCode() { + return errorCode; + } + + public void setErrorCode(String value) { + this.errorCode = value; + } + + public String getErrorText() { + return errorText; + } + + public void setErrorText(String value) { + this.errorText = value; + } + + public Long getInSDfId() { + return inSDfId; + } + + public void setInSDfId(Long value) { + this.inSDfId = value; + } + + public Long getOutSDfId() { + return outSDfId; + } + + public void setOutSDfId(Long value) { + this.outSDfId = value; + } + +} \ No newline at end of file diff --git a/clearing-parent/db-scripts/src/main/resources/db/DDL.sql b/clearing-parent/db-scripts/src/main/resources/db/DDL.sql index 454a5e289..7e7ddb7dd 100644 --- a/clearing-parent/db-scripts/src/main/resources/db/DDL.sql +++ b/clearing-parent/db-scripts/src/main/resources/db/DDL.sql @@ -414,44 +414,44 @@ COMMENT ON COLUMN COMPANY_INFO.CLEARING_CODE IS 'Код участника кл COMMENT ON COLUMN COMPANY_INFO.REGISTRATION_CODE IS 'Регистрационный код участника'; --- Update log of companyInfo - Профиль Компании -CREATE TABLE IF NOT EXISTS COMPANY_INFO_UPDATE(COMPANY_INFO_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, COMPANY_ID bigint, CORPORATION_SOLE_TYPE char(4), COUNTRY_CODE char(4), DESCRIPTION varchar, PROFESSIONAL_SIGN char(4), LEGAL_KIND char(4), ORGANIZATION_TYPE char(4), RESIDENCE char(4), SHORT_NAME_ENG varchar(255), FULL_NAME_ENG varchar(255), SHORT_NAME varchar(255), FULL_NAME varchar(255), TRADING_CODE varchar(255), CLEARING_CODE varchar(255), REGISTRATION_CODE varchar(255)); -COMMENT ON TABLE COMPANY_INFO_UPDATE IS 'Журнал изменений таблицы companyInfo'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.COMPANY_INFO_ID IS 'Идентификатор записи в таблице COMPANY_INFO'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of companyInfo - Профиль Компании +CREATE TABLE IF NOT EXISTS COMPANY_INFO_HISTORY(COMPANY_INFO_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, COMPANY_ID bigint, CORPORATION_SOLE_TYPE char(4), COUNTRY_CODE char(4), DESCRIPTION varchar, PROFESSIONAL_SIGN char(4), LEGAL_KIND char(4), ORGANIZATION_TYPE char(4), RESIDENCE char(4), SHORT_NAME_ENG varchar(255), FULL_NAME_ENG varchar(255), SHORT_NAME varchar(255), FULL_NAME varchar(255), TRADING_CODE varchar(255), CLEARING_CODE varchar(255), REGISTRATION_CODE varchar(255)); +COMMENT ON TABLE COMPANY_INFO_HISTORY IS 'История изменений таблицы companyInfo'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.COMPANY_INFO_ID IS 'Идентификатор записи в таблице COMPANY_INFO'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.ID IS 'Идентификатор записи'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.COMPANY_ID IS 'Идентификатор Компании (linked to company)'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.COMPANY_ID IS 'Идентификатор Компании (linked to company)'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.CORPORATION_SOLE_TYPE IS 'Идентификатор единоличного исполнительного органа (linked to corporationSoleType)'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.CORPORATION_SOLE_TYPE IS 'Идентификатор единоличного исполнительного органа (linked to corporationSoleType)'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.COUNTRY_CODE IS 'Идентификатор кода страны (linked to countryCode)'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.COUNTRY_CODE IS 'Идентификатор кода страны (linked to countryCode)'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.DESCRIPTION IS 'Описание'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.DESCRIPTION IS 'Описание'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.PROFESSIONAL_SIGN IS 'Признак проф. Участника (linked to allowed)'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.PROFESSIONAL_SIGN IS 'Признак проф. Участника (linked to allowed)'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.LEGAL_KIND IS 'Идентификатор вида субъекта (linked to legalKind)'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.LEGAL_KIND IS 'Идентификатор вида субъекта (linked to legalKind)'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.ORGANIZATION_TYPE IS 'Идентификатор типа организации (linked to organizationType)'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.ORGANIZATION_TYPE IS 'Идентификатор типа организации (linked to organizationType)'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.RESIDENCE IS 'Идентификатор кода страны (linked to countryCode)'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.RESIDENCE IS 'Идентификатор кода страны (linked to countryCode)'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.SHORT_NAME_ENG IS 'Краткое наименование Компании на английском'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.SHORT_NAME_ENG IS 'Краткое наименование Компании на английском'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.FULL_NAME_ENG IS 'Полное наименование Компании на английском'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.FULL_NAME_ENG IS 'Полное наименование Компании на английском'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.SHORT_NAME IS 'Краткое наименование Компании'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.SHORT_NAME IS 'Краткое наименование Компании'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.FULL_NAME IS 'Полное наименование Компании'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.FULL_NAME IS 'Полное наименование Компании'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.TRADING_CODE IS 'Код участника торгов'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.TRADING_CODE IS 'Код участника торгов'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.CLEARING_CODE IS 'Код участника клиринга'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.CLEARING_CODE IS 'Код участника клиринга'; -COMMENT ON COLUMN COMPANY_INFO_UPDATE.REGISTRATION_CODE IS 'Регистрационный код участника'; +COMMENT ON COLUMN COMPANY_INFO_HISTORY.REGISTRATION_CODE IS 'Регистрационный код участника'; -- clearingMemberCategory - Категории Участника клиринга CREATE TABLE IF NOT EXISTS CLEARING_MEMBER_CATEGORY(ID bigint PRIMARY KEY, COMPANY_ID bigint, CLEARING_MEMBER_CATEGORY char(4)); @@ -565,28 +565,28 @@ COMMENT ON COLUMN ACCOUNT.STATUS IS 'Идентификатор статуса ( COMMENT ON COLUMN ACCOUNT.PROCESSING_SIGN IS 'Признак обработки счета (linked to allowed)'; --- Update log of account - Счета -CREATE TABLE IF NOT EXISTS ACCOUNT_UPDATE(ACCOUNT_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, ACCOUNT varchar(12), ACCOUNT_TYPE char(4), RELATION_ID bigint, STATUS char(4), PROCESSING_SIGN char(4)); -COMMENT ON TABLE ACCOUNT_UPDATE IS 'Журнал изменений таблицы account'; -COMMENT ON COLUMN ACCOUNT_UPDATE.ACCOUNT_ID IS 'Идентификатор записи в таблице ACCOUNT'; -COMMENT ON COLUMN ACCOUNT_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN ACCOUNT_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of account - Счета +CREATE TABLE IF NOT EXISTS ACCOUNT_HISTORY(ACCOUNT_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, ACCOUNT varchar(12), ACCOUNT_TYPE char(4), RELATION_ID bigint, STATUS char(4), PROCESSING_SIGN char(4)); +COMMENT ON TABLE ACCOUNT_HISTORY IS 'История изменений таблицы account'; +COMMENT ON COLUMN ACCOUNT_HISTORY.ACCOUNT_ID IS 'Идентификатор записи в таблице ACCOUNT'; +COMMENT ON COLUMN ACCOUNT_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN ACCOUNT_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN ACCOUNT_UPDATE.ID IS 'Идентификатор'; +COMMENT ON COLUMN ACCOUNT_HISTORY.ID IS 'Идентификатор'; -COMMENT ON COLUMN ACCOUNT_UPDATE.CREATED_AT IS 'Дата и время создания записи'; +COMMENT ON COLUMN ACCOUNT_HISTORY.CREATED_AT IS 'Дата и время создания записи'; -COMMENT ON COLUMN ACCOUNT_UPDATE.UPDATED_AT IS 'Дата и время изменения записи'; +COMMENT ON COLUMN ACCOUNT_HISTORY.UPDATED_AT IS 'Дата и время изменения записи'; -COMMENT ON COLUMN ACCOUNT_UPDATE.ACCOUNT IS 'Номер счета'; +COMMENT ON COLUMN ACCOUNT_HISTORY.ACCOUNT IS 'Номер счета'; -COMMENT ON COLUMN ACCOUNT_UPDATE.ACCOUNT_TYPE IS 'Идентификатор типа счета (linked to accountType)'; +COMMENT ON COLUMN ACCOUNT_HISTORY.ACCOUNT_TYPE IS 'Идентификатор типа счета (linked to accountType)'; -COMMENT ON COLUMN ACCOUNT_UPDATE.RELATION_ID IS 'Идентификатор договорных отношений (linked to relation)'; +COMMENT ON COLUMN ACCOUNT_HISTORY.RELATION_ID IS 'Идентификатор договорных отношений (linked to relation)'; -COMMENT ON COLUMN ACCOUNT_UPDATE.STATUS IS 'Идентификатор статуса (linked to workflowStatus)'; +COMMENT ON COLUMN ACCOUNT_HISTORY.STATUS IS 'Идентификатор статуса (linked to workflowStatus)'; -COMMENT ON COLUMN ACCOUNT_UPDATE.PROCESSING_SIGN IS 'Признак обработки счета (linked to allowed)'; +COMMENT ON COLUMN ACCOUNT_HISTORY.PROCESSING_SIGN IS 'Признак обработки счета (linked to allowed)'; -- relation - Договорные отношения CREATE TABLE IF NOT EXISTS RELATION(ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, CONSUMER_ID bigint, SUPPLIER_ID bigint, SERVICE_STATUS char(4), SERVICE char(4), SERVICE_PRODUCT char(4), COMMENT varchar(255)); @@ -611,30 +611,30 @@ COMMENT ON COLUMN RELATION.SERVICE_PRODUCT IS 'Идентификатор про COMMENT ON COLUMN RELATION.COMMENT IS 'Текст причины'; --- Update log of relation - Договорные отношения -CREATE TABLE IF NOT EXISTS RELATION_UPDATE(RELATION_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, CONSUMER_ID bigint, SUPPLIER_ID bigint, SERVICE_STATUS char(4), SERVICE char(4), SERVICE_PRODUCT char(4), COMMENT varchar(255)); -COMMENT ON TABLE RELATION_UPDATE IS 'Журнал изменений таблицы relation'; -COMMENT ON COLUMN RELATION_UPDATE.RELATION_ID IS 'Идентификатор записи в таблице RELATION'; -COMMENT ON COLUMN RELATION_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN RELATION_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of relation - Договорные отношения +CREATE TABLE IF NOT EXISTS RELATION_HISTORY(RELATION_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, CONSUMER_ID bigint, SUPPLIER_ID bigint, SERVICE_STATUS char(4), SERVICE char(4), SERVICE_PRODUCT char(4), COMMENT varchar(255)); +COMMENT ON TABLE RELATION_HISTORY IS 'История изменений таблицы relation'; +COMMENT ON COLUMN RELATION_HISTORY.RELATION_ID IS 'Идентификатор записи в таблице RELATION'; +COMMENT ON COLUMN RELATION_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN RELATION_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN RELATION_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN RELATION_HISTORY.ID IS 'Идентификатор записи'; -COMMENT ON COLUMN RELATION_UPDATE.CREATED_AT IS 'Дата и время создания записи'; +COMMENT ON COLUMN RELATION_HISTORY.CREATED_AT IS 'Дата и время создания записи'; -COMMENT ON COLUMN RELATION_UPDATE.UPDATED_AT IS 'Дата и время изменения записи'; +COMMENT ON COLUMN RELATION_HISTORY.UPDATED_AT IS 'Дата и время изменения записи'; -COMMENT ON COLUMN RELATION_UPDATE.CONSUMER_ID IS 'Идентификатор Компании пользователя услуги (linked to company)'; +COMMENT ON COLUMN RELATION_HISTORY.CONSUMER_ID IS 'Идентификатор Компании пользователя услуги (linked to company)'; -COMMENT ON COLUMN RELATION_UPDATE.SUPPLIER_ID IS 'Идентификатор Компании поставщика услуги (linked to company)'; +COMMENT ON COLUMN RELATION_HISTORY.SUPPLIER_ID IS 'Идентификатор Компании поставщика услуги (linked to company)'; -COMMENT ON COLUMN RELATION_UPDATE.SERVICE_STATUS IS 'Идентификатор статуса (linked to workflowStatus)'; +COMMENT ON COLUMN RELATION_HISTORY.SERVICE_STATUS IS 'Идентификатор статуса (linked to workflowStatus)'; -COMMENT ON COLUMN RELATION_UPDATE.SERVICE IS 'Идентификатор сервиса (linked to service)'; +COMMENT ON COLUMN RELATION_HISTORY.SERVICE IS 'Идентификатор сервиса (linked to service)'; -COMMENT ON COLUMN RELATION_UPDATE.SERVICE_PRODUCT IS 'Идентификатор продукта (linked to serviceProduct)'; +COMMENT ON COLUMN RELATION_HISTORY.SERVICE_PRODUCT IS 'Идентификатор продукта (linked to serviceProduct)'; -COMMENT ON COLUMN RELATION_UPDATE.COMMENT IS 'Текст причины'; +COMMENT ON COLUMN RELATION_HISTORY.COMMENT IS 'Текст причины'; -- bankAccount - Банковские реквизиты для перечисления денежных средств CREATE TABLE IF NOT EXISTS BANK_ACCOUNT(ID bigint PRIMARY KEY, ACCOUNT_ID bigint, BANK_IDENTIFICATION_CODE varchar(255), BANK_NAME varchar(255), CORRESPONDENT_ACCOUNT varchar(255), CORRESPONDENT_ACCOUNT_NAME varchar(255), CURRENCY char(4), DESTINATION varchar(255), IBAN varchar(255), INTERNATIONAL_TRANSFER_SIGN char(4), SWIFT_CODE varchar(255), TAXPAYER_IDENTIFICATION_NUMBER varchar(255), TAX_REGISTRATION_REASON_CODE varchar(255), ACCOUNT varchar(12)); @@ -669,40 +669,40 @@ COMMENT ON COLUMN BANK_ACCOUNT.TAX_REGISTRATION_REASON_CODE IS 'Код прич COMMENT ON COLUMN BANK_ACCOUNT.ACCOUNT IS 'Номер счета (linked to account)'; --- Update log of bankAccount - Банковские реквизиты для перечисления денежных средств -CREATE TABLE IF NOT EXISTS BANK_ACCOUNT_UPDATE(BANK_ACCOUNT_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, ACCOUNT_ID bigint, BANK_IDENTIFICATION_CODE varchar(255), BANK_NAME varchar(255), CORRESPONDENT_ACCOUNT varchar(255), CORRESPONDENT_ACCOUNT_NAME varchar(255), CURRENCY char(4), DESTINATION varchar(255), IBAN varchar(255), INTERNATIONAL_TRANSFER_SIGN char(4), SWIFT_CODE varchar(255), TAXPAYER_IDENTIFICATION_NUMBER varchar(255), TAX_REGISTRATION_REASON_CODE varchar(255), ACCOUNT varchar(12)); -COMMENT ON TABLE BANK_ACCOUNT_UPDATE IS 'Журнал изменений таблицы bankAccount'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.BANK_ACCOUNT_ID IS 'Идентификатор записи в таблице BANK_ACCOUNT'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of bankAccount - Банковские реквизиты для перечисления денежных средств +CREATE TABLE IF NOT EXISTS BANK_ACCOUNT_HISTORY(BANK_ACCOUNT_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, ACCOUNT_ID bigint, BANK_IDENTIFICATION_CODE varchar(255), BANK_NAME varchar(255), CORRESPONDENT_ACCOUNT varchar(255), CORRESPONDENT_ACCOUNT_NAME varchar(255), CURRENCY char(4), DESTINATION varchar(255), IBAN varchar(255), INTERNATIONAL_TRANSFER_SIGN char(4), SWIFT_CODE varchar(255), TAXPAYER_IDENTIFICATION_NUMBER varchar(255), TAX_REGISTRATION_REASON_CODE varchar(255), ACCOUNT varchar(12)); +COMMENT ON TABLE BANK_ACCOUNT_HISTORY IS 'История изменений таблицы bankAccount'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.BANK_ACCOUNT_ID IS 'Идентификатор записи в таблице BANK_ACCOUNT'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.ID IS 'Идентификатор записи'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.ACCOUNT_ID IS 'Идентификатор счета (linked to account)'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.ACCOUNT_ID IS 'Идентификатор счета (linked to account)'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.BANK_IDENTIFICATION_CODE IS 'Банковский идентификационный код (БИК)'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.BANK_IDENTIFICATION_CODE IS 'Банковский идентификационный код (БИК)'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.BANK_NAME IS 'Наименование банка'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.BANK_NAME IS 'Наименование банка'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.CORRESPONDENT_ACCOUNT IS 'Корреспондентский счет'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.CORRESPONDENT_ACCOUNT IS 'Корреспондентский счет'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.CORRESPONDENT_ACCOUNT_NAME IS 'Наименование корреспондентского счета'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.CORRESPONDENT_ACCOUNT_NAME IS 'Наименование корреспондентского счета'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.CURRENCY IS 'Идентификатор валюты (linked to currencyCode)'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.CURRENCY IS 'Идентификатор валюты (linked to currencyCode)'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.DESTINATION IS 'Назначение'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.DESTINATION IS 'Назначение'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.IBAN IS 'Международный номер банковского счета'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.IBAN IS 'Международный номер банковского счета'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.INTERNATIONAL_TRANSFER_SIGN IS 'Доступность международных переводов (linked to allowed)'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.INTERNATIONAL_TRANSFER_SIGN IS 'Доступность международных переводов (linked to allowed)'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.SWIFT_CODE IS 'Код SWIFT'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.SWIFT_CODE IS 'Код SWIFT'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.TAXPAYER_IDENTIFICATION_NUMBER IS 'Идентификационный номер налогоплательщика (ИНН)'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.TAXPAYER_IDENTIFICATION_NUMBER IS 'Идентификационный номер налогоплательщика (ИНН)'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.TAX_REGISTRATION_REASON_CODE IS 'Код причины постановки (КПП)'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.TAX_REGISTRATION_REASON_CODE IS 'Код причины постановки (КПП)'; -COMMENT ON COLUMN BANK_ACCOUNT_UPDATE.ACCOUNT IS 'Номер счета (linked to account)'; +COMMENT ON COLUMN BANK_ACCOUNT_HISTORY.ACCOUNT IS 'Номер счета (linked to account)'; -- clearingAccount - Клиринговые счета CREATE TABLE IF NOT EXISTS CLEARING_ACCOUNT(ID bigint PRIMARY KEY, ACCOUNT_ID bigint, ACCOUNT varchar(12)); @@ -715,18 +715,18 @@ COMMENT ON COLUMN CLEARING_ACCOUNT.ACCOUNT_ID IS 'Идентификатор с COMMENT ON COLUMN CLEARING_ACCOUNT.ACCOUNT IS 'Номер счета (linked to account)'; --- Update log of clearingAccount - Клиринговые счета -CREATE TABLE IF NOT EXISTS CLEARING_ACCOUNT_UPDATE(CLEARING_ACCOUNT_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, ACCOUNT_ID bigint, ACCOUNT varchar(12)); -COMMENT ON TABLE CLEARING_ACCOUNT_UPDATE IS 'Журнал изменений таблицы clearingAccount'; -COMMENT ON COLUMN CLEARING_ACCOUNT_UPDATE.CLEARING_ACCOUNT_ID IS 'Идентификатор записи в таблице CLEARING_ACCOUNT'; -COMMENT ON COLUMN CLEARING_ACCOUNT_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN CLEARING_ACCOUNT_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of clearingAccount - Клиринговые счета +CREATE TABLE IF NOT EXISTS CLEARING_ACCOUNT_HISTORY(CLEARING_ACCOUNT_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, ACCOUNT_ID bigint, ACCOUNT varchar(12)); +COMMENT ON TABLE CLEARING_ACCOUNT_HISTORY IS 'История изменений таблицы clearingAccount'; +COMMENT ON COLUMN CLEARING_ACCOUNT_HISTORY.CLEARING_ACCOUNT_ID IS 'Идентификатор записи в таблице CLEARING_ACCOUNT'; +COMMENT ON COLUMN CLEARING_ACCOUNT_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN CLEARING_ACCOUNT_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN CLEARING_ACCOUNT_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN CLEARING_ACCOUNT_HISTORY.ID IS 'Идентификатор записи'; -COMMENT ON COLUMN CLEARING_ACCOUNT_UPDATE.ACCOUNT_ID IS 'Идентификатор счета (linked to account)'; +COMMENT ON COLUMN CLEARING_ACCOUNT_HISTORY.ACCOUNT_ID IS 'Идентификатор счета (linked to account)'; -COMMENT ON COLUMN CLEARING_ACCOUNT_UPDATE.ACCOUNT IS 'Номер счета (linked to account)'; +COMMENT ON COLUMN CLEARING_ACCOUNT_HISTORY.ACCOUNT IS 'Номер счета (linked to account)'; -- informationAccount - Информационные счета CREATE TABLE IF NOT EXISTS INFORMATION_ACCOUNT(ID bigint PRIMARY KEY, ACCOUNT_ID bigint, ACCOUNT varchar(12), CLEARING_ACCOUNT_ID bigint); @@ -741,20 +741,20 @@ COMMENT ON COLUMN INFORMATION_ACCOUNT.ACCOUNT IS 'Номер счета (linked COMMENT ON COLUMN INFORMATION_ACCOUNT.CLEARING_ACCOUNT_ID IS 'Идентификатор клирингового счета (linked to clearingAccount)'; --- Update log of informationAccount - Информационные счета -CREATE TABLE IF NOT EXISTS INFORMATION_ACCOUNT_UPDATE(INFORMATION_ACCOUNT_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, ACCOUNT_ID bigint, ACCOUNT varchar(12), CLEARING_ACCOUNT_ID bigint); -COMMENT ON TABLE INFORMATION_ACCOUNT_UPDATE IS 'Журнал изменений таблицы informationAccount'; -COMMENT ON COLUMN INFORMATION_ACCOUNT_UPDATE.INFORMATION_ACCOUNT_ID IS 'Идентификатор записи в таблице INFORMATION_ACCOUNT'; -COMMENT ON COLUMN INFORMATION_ACCOUNT_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN INFORMATION_ACCOUNT_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of informationAccount - Информационные счета +CREATE TABLE IF NOT EXISTS INFORMATION_ACCOUNT_HISTORY(INFORMATION_ACCOUNT_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, ACCOUNT_ID bigint, ACCOUNT varchar(12), CLEARING_ACCOUNT_ID bigint); +COMMENT ON TABLE INFORMATION_ACCOUNT_HISTORY IS 'История изменений таблицы informationAccount'; +COMMENT ON COLUMN INFORMATION_ACCOUNT_HISTORY.INFORMATION_ACCOUNT_ID IS 'Идентификатор записи в таблице INFORMATION_ACCOUNT'; +COMMENT ON COLUMN INFORMATION_ACCOUNT_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN INFORMATION_ACCOUNT_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN INFORMATION_ACCOUNT_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN INFORMATION_ACCOUNT_HISTORY.ID IS 'Идентификатор записи'; -COMMENT ON COLUMN INFORMATION_ACCOUNT_UPDATE.ACCOUNT_ID IS 'Идентификатор счета (linked to account)'; +COMMENT ON COLUMN INFORMATION_ACCOUNT_HISTORY.ACCOUNT_ID IS 'Идентификатор счета (linked to account)'; -COMMENT ON COLUMN INFORMATION_ACCOUNT_UPDATE.ACCOUNT IS 'Номер счета (linked to account)'; +COMMENT ON COLUMN INFORMATION_ACCOUNT_HISTORY.ACCOUNT IS 'Номер счета (linked to account)'; -COMMENT ON COLUMN INFORMATION_ACCOUNT_UPDATE.CLEARING_ACCOUNT_ID IS 'Идентификатор клирингового счета (linked to clearingAccount)'; +COMMENT ON COLUMN INFORMATION_ACCOUNT_HISTORY.CLEARING_ACCOUNT_ID IS 'Идентификатор клирингового счета (linked to clearingAccount)'; -- accountRouting - Маршрутизация счета CREATE TABLE IF NOT EXISTS ACCOUNT_ROUTING(ID bigint PRIMARY KEY, DESTINATION_ID bigint, RELATION_ID bigint, SOURCE_ID bigint); @@ -769,20 +769,20 @@ COMMENT ON COLUMN ACCOUNT_ROUTING.RELATION_ID IS 'Идентификатор д COMMENT ON COLUMN ACCOUNT_ROUTING.SOURCE_ID IS 'Счет-источник (списания) (linked to account)'; --- Update log of accountRouting - Маршрутизация счета -CREATE TABLE IF NOT EXISTS ACCOUNT_ROUTING_UPDATE(ACCOUNT_ROUTING_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, DESTINATION_ID bigint, RELATION_ID bigint, SOURCE_ID bigint); -COMMENT ON TABLE ACCOUNT_ROUTING_UPDATE IS 'Журнал изменений таблицы accountRouting'; -COMMENT ON COLUMN ACCOUNT_ROUTING_UPDATE.ACCOUNT_ROUTING_ID IS 'Идентификатор записи в таблице ACCOUNT_ROUTING'; -COMMENT ON COLUMN ACCOUNT_ROUTING_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN ACCOUNT_ROUTING_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of accountRouting - Маршрутизация счета +CREATE TABLE IF NOT EXISTS ACCOUNT_ROUTING_HISTORY(ACCOUNT_ROUTING_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, DESTINATION_ID bigint, RELATION_ID bigint, SOURCE_ID bigint); +COMMENT ON TABLE ACCOUNT_ROUTING_HISTORY IS 'История изменений таблицы accountRouting'; +COMMENT ON COLUMN ACCOUNT_ROUTING_HISTORY.ACCOUNT_ROUTING_ID IS 'Идентификатор записи в таблице ACCOUNT_ROUTING'; +COMMENT ON COLUMN ACCOUNT_ROUTING_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN ACCOUNT_ROUTING_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN ACCOUNT_ROUTING_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN ACCOUNT_ROUTING_HISTORY.ID IS 'Идентификатор записи'; -COMMENT ON COLUMN ACCOUNT_ROUTING_UPDATE.DESTINATION_ID IS 'Счет-назначение (зачисления) (linked to account)'; +COMMENT ON COLUMN ACCOUNT_ROUTING_HISTORY.DESTINATION_ID IS 'Счет-назначение (зачисления) (linked to account)'; -COMMENT ON COLUMN ACCOUNT_ROUTING_UPDATE.RELATION_ID IS 'Идентификатор договорных отношений (linked to relation)'; +COMMENT ON COLUMN ACCOUNT_ROUTING_HISTORY.RELATION_ID IS 'Идентификатор договорных отношений (linked to relation)'; -COMMENT ON COLUMN ACCOUNT_ROUTING_UPDATE.SOURCE_ID IS 'Счет-источник (списания) (linked to account)'; +COMMENT ON COLUMN ACCOUNT_ROUTING_HISTORY.SOURCE_ID IS 'Счет-источник (списания) (linked to account)'; -- security - Инструменты CREATE TABLE IF NOT EXISTS SECURITY(ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, INSTRUMENT_TYPE char(4), ISSUER_ID bigint, SHORT_NAME varchar(255), FULL_NAME varchar(255), SHORT_NAME_ENG varchar(255), FULL_NAME_ENG varchar(255), SECURITY_SYMBOL varchar(255), WORKFLOW_STATUS char(4)); @@ -811,34 +811,34 @@ COMMENT ON COLUMN SECURITY.SECURITY_SYMBOL IS 'Код инструмента'; COMMENT ON COLUMN SECURITY.WORKFLOW_STATUS IS 'Идентификатор статуса (linked to workflowStatus)'; --- Update log of security - Инструменты -CREATE TABLE IF NOT EXISTS SECURITY_UPDATE(SECURITY_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, INSTRUMENT_TYPE char(4), ISSUER_ID bigint, SHORT_NAME varchar(255), FULL_NAME varchar(255), SHORT_NAME_ENG varchar(255), FULL_NAME_ENG varchar(255), SECURITY_SYMBOL varchar(255), WORKFLOW_STATUS char(4)); -COMMENT ON TABLE SECURITY_UPDATE IS 'Журнал изменений таблицы security'; -COMMENT ON COLUMN SECURITY_UPDATE.SECURITY_ID IS 'Идентификатор записи в таблице SECURITY'; -COMMENT ON COLUMN SECURITY_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN SECURITY_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of security - Инструменты +CREATE TABLE IF NOT EXISTS SECURITY_HISTORY(SECURITY_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, INSTRUMENT_TYPE char(4), ISSUER_ID bigint, SHORT_NAME varchar(255), FULL_NAME varchar(255), SHORT_NAME_ENG varchar(255), FULL_NAME_ENG varchar(255), SECURITY_SYMBOL varchar(255), WORKFLOW_STATUS char(4)); +COMMENT ON TABLE SECURITY_HISTORY IS 'История изменений таблицы security'; +COMMENT ON COLUMN SECURITY_HISTORY.SECURITY_ID IS 'Идентификатор записи в таблице SECURITY'; +COMMENT ON COLUMN SECURITY_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN SECURITY_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN SECURITY_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN SECURITY_HISTORY.ID IS 'Идентификатор записи'; -COMMENT ON COLUMN SECURITY_UPDATE.CREATED_AT IS 'Дата и время создания записи'; +COMMENT ON COLUMN SECURITY_HISTORY.CREATED_AT IS 'Дата и время создания записи'; -COMMENT ON COLUMN SECURITY_UPDATE.UPDATED_AT IS 'Дата и время изменения записи'; +COMMENT ON COLUMN SECURITY_HISTORY.UPDATED_AT IS 'Дата и время изменения записи'; -COMMENT ON COLUMN SECURITY_UPDATE.INSTRUMENT_TYPE IS 'Идентификатор типа инструмента (linked to instrumentType)'; +COMMENT ON COLUMN SECURITY_HISTORY.INSTRUMENT_TYPE IS 'Идентификатор типа инструмента (linked to instrumentType)'; -COMMENT ON COLUMN SECURITY_UPDATE.ISSUER_ID IS 'Идентификатор эмитента (linked to company)'; +COMMENT ON COLUMN SECURITY_HISTORY.ISSUER_ID IS 'Идентификатор эмитента (linked to company)'; -COMMENT ON COLUMN SECURITY_UPDATE.SHORT_NAME IS 'Краткое наименование инструмента'; +COMMENT ON COLUMN SECURITY_HISTORY.SHORT_NAME IS 'Краткое наименование инструмента'; -COMMENT ON COLUMN SECURITY_UPDATE.FULL_NAME IS 'Полное наименование инструмента'; +COMMENT ON COLUMN SECURITY_HISTORY.FULL_NAME IS 'Полное наименование инструмента'; -COMMENT ON COLUMN SECURITY_UPDATE.SHORT_NAME_ENG IS 'Краткое наименование инструмента на английском'; +COMMENT ON COLUMN SECURITY_HISTORY.SHORT_NAME_ENG IS 'Краткое наименование инструмента на английском'; -COMMENT ON COLUMN SECURITY_UPDATE.FULL_NAME_ENG IS 'Полное наименование инструмента на английском'; +COMMENT ON COLUMN SECURITY_HISTORY.FULL_NAME_ENG IS 'Полное наименование инструмента на английском'; -COMMENT ON COLUMN SECURITY_UPDATE.SECURITY_SYMBOL IS 'Код инструмента'; +COMMENT ON COLUMN SECURITY_HISTORY.SECURITY_SYMBOL IS 'Код инструмента'; -COMMENT ON COLUMN SECURITY_UPDATE.WORKFLOW_STATUS IS 'Идентификатор статуса (linked to workflowStatus)'; +COMMENT ON COLUMN SECURITY_HISTORY.WORKFLOW_STATUS IS 'Идентификатор статуса (linked to workflowStatus)'; -- currency - Инструменты Валюты CREATE TABLE IF NOT EXISTS CURRENCY(ID bigint PRIMARY KEY, COUNTRY_CODE char(4), CURRENCY_CODE char(4)); @@ -851,21 +851,21 @@ COMMENT ON COLUMN CURRENCY.COUNTRY_CODE IS 'Идентификатор кода COMMENT ON COLUMN CURRENCY.CURRENCY_CODE IS 'Идентификатор кода валюты (linked to currencyCode)'; --- Update log of currency - Инструменты Валюты -CREATE TABLE IF NOT EXISTS CURRENCY_UPDATE(CURRENCY_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, COUNTRY_CODE char(4), CURRENCY_CODE char(4)); -COMMENT ON TABLE CURRENCY_UPDATE IS 'Журнал изменений таблицы currency'; -COMMENT ON COLUMN CURRENCY_UPDATE.CURRENCY_ID IS 'Идентификатор записи в таблице CURRENCY'; -COMMENT ON COLUMN CURRENCY_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN CURRENCY_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of currency - Инструменты Валюты +CREATE TABLE IF NOT EXISTS CURRENCY_HISTORY(CURRENCY_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, COUNTRY_CODE char(4), CURRENCY_CODE char(4)); +COMMENT ON TABLE CURRENCY_HISTORY IS 'История изменений таблицы currency'; +COMMENT ON COLUMN CURRENCY_HISTORY.CURRENCY_ID IS 'Идентификатор записи в таблице CURRENCY'; +COMMENT ON COLUMN CURRENCY_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN CURRENCY_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN CURRENCY_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN CURRENCY_HISTORY.ID IS 'Идентификатор записи'; -COMMENT ON COLUMN CURRENCY_UPDATE.COUNTRY_CODE IS 'Идентификатор кода страны (linked to countryCode)'; +COMMENT ON COLUMN CURRENCY_HISTORY.COUNTRY_CODE IS 'Идентификатор кода страны (linked to countryCode)'; -COMMENT ON COLUMN CURRENCY_UPDATE.CURRENCY_CODE IS 'Идентификатор кода валюты (linked to currencyCode)'; +COMMENT ON COLUMN CURRENCY_HISTORY.CURRENCY_CODE IS 'Идентификатор кода валюты (linked to currencyCode)'; -- moneyMarketSecurity - Инструменты Денежного рынка -CREATE TABLE IF NOT EXISTS MONEY_MARKET_SECURITY(ID bigint PRIMARY KEY, SECURITY_ID bigint, DESCRIPTION varchar(255), START_DATE date, END_DATE date, NOMINAL_VALUE numeric(72,2), NOMINAL_CURRENCY bigint, INSTRUMENT_TYPE char(4), FULL_NAME varchar(255), SECURITY_SYMBOL varchar(255), TERM_TYPE char(4), ID numeric(72,2) PRIMARY KEY); +CREATE TABLE IF NOT EXISTS MONEY_MARKET_SECURITY(ID bigint PRIMARY KEY, SECURITY_ID bigint, DESCRIPTION varchar(255), START_DATE date, END_DATE date, NOMINAL_VALUE numeric(72,2), NOMINAL_CURRENCY bigint, INSTRUMENT_TYPE char(4), FULL_NAME varchar(255), SECURITY_SYMBOL varchar(255), TERM_TYPE char(4)); COMMENT ON TABLE MONEY_MARKET_SECURITY IS 'Инструменты Денежного рынка'; COMMENT ON COLUMN MONEY_MARKET_SECURITY.ID IS 'Идентификатор записи'; @@ -890,42 +890,34 @@ COMMENT ON COLUMN MONEY_MARKET_SECURITY.SECURITY_SYMBOL IS 'Код инстру COMMENT ON COLUMN MONEY_MARKET_SECURITY.TERM_TYPE IS 'Идентификатор вида инструмента (linked to termType)'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY.ID IS 'Размер лота (linked to listing)'; +-- History log of moneyMarketSecurity - Инструменты Денежного рынка +CREATE TABLE IF NOT EXISTS MONEY_MARKET_SECURITY_HISTORY(MONEY_MARKET_SECURITY_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, SECURITY_ID bigint, DESCRIPTION varchar(255), START_DATE date, END_DATE date, NOMINAL_VALUE numeric(72,2), NOMINAL_CURRENCY bigint, INSTRUMENT_TYPE char(4), FULL_NAME varchar(255), SECURITY_SYMBOL varchar(255), TERM_TYPE char(4)); +COMMENT ON TABLE MONEY_MARKET_SECURITY_HISTORY IS 'История изменений таблицы moneyMarketSecurity'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.MONEY_MARKET_SECURITY_ID IS 'Идентификатор записи в таблице MONEY_MARKET_SECURITY'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY.ACTIONS IS ''; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.SECURITY_ID IS 'Идентификатор инструмента (linked to security)'; --- Update log of moneyMarketSecurity - Инструменты Денежного рынка -CREATE TABLE IF NOT EXISTS MONEY_MARKET_SECURITY_UPDATE(MONEY_MARKET_SECURITY_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, SECURITY_ID bigint, DESCRIPTION varchar(255), START_DATE date, END_DATE date, NOMINAL_VALUE numeric(72,2), NOMINAL_CURRENCY bigint, INSTRUMENT_TYPE char(4), FULL_NAME varchar(255), SECURITY_SYMBOL varchar(255), TERM_TYPE char(4), ID numeric(72,2) PRIMARY KEY); -COMMENT ON TABLE MONEY_MARKET_SECURITY_UPDATE IS 'Журнал изменений таблицы moneyMarketSecurity'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.MONEY_MARKET_SECURITY_ID IS 'Идентификатор записи в таблице MONEY_MARKET_SECURITY'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.DESCRIPTION IS 'Описание'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.START_DATE IS 'Дата начала действия'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.SECURITY_ID IS 'Идентификатор инструмента (linked to security)'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.END_DATE IS 'Дата окончания действия'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.DESCRIPTION IS 'Описание'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.NOMINAL_VALUE IS 'Номинал'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.START_DATE IS 'Дата начала действия'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.NOMINAL_CURRENCY IS 'Валюта номинала (linked to currencyCode)'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.END_DATE IS 'Дата окончания действия'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.INSTRUMENT_TYPE IS 'Идентификатор типа инструмента (linked to instrumentType)'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.NOMINAL_VALUE IS 'Номинал'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.FULL_NAME IS 'Полное наименование инструмента'; -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.NOMINAL_CURRENCY IS 'Валюта номинала (linked to currencyCode)'; - -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.INSTRUMENT_TYPE IS 'Идентификатор типа инструмента (linked to instrumentType)'; - -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.FULL_NAME IS 'Полное наименование инструмента'; - -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.SECURITY_SYMBOL IS 'Код инструмента'; - -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.TERM_TYPE IS 'Идентификатор вида инструмента (linked to termType)'; - -COMMENT ON COLUMN MONEY_MARKET_SECURITY_UPDATE.ID IS 'Размер лота (linked to listing)'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.SECURITY_SYMBOL IS 'Код инструмента'; +COMMENT ON COLUMN MONEY_MARKET_SECURITY_HISTORY.TERM_TYPE IS 'Идентификатор вида инструмента (linked to termType)'; -- listing - Листинг инструментов CREATE TABLE IF NOT EXISTS LISTING(ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, SECURITY_ID bigint, LOT_SIZE numeric(72,2), MARKET_ID bigint, SYMBOL_CODE varchar(255), SYMBOL_NAME varchar(255), TRADING_CURRENCY char(4), WORKFLOW_STATUS char(4)); @@ -952,32 +944,32 @@ COMMENT ON COLUMN LISTING.TRADING_CURRENCY IS 'Идентификатор код COMMENT ON COLUMN LISTING.WORKFLOW_STATUS IS 'Идентификатор статуса листинга в системе (linked to workflowStatus)'; --- Update log of listing - Листинг инструментов -CREATE TABLE IF NOT EXISTS LISTING_UPDATE(LISTING_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, SECURITY_ID bigint, LOT_SIZE numeric(72,2), MARKET_ID bigint, SYMBOL_CODE varchar(255), SYMBOL_NAME varchar(255), TRADING_CURRENCY char(4), WORKFLOW_STATUS char(4)); -COMMENT ON TABLE LISTING_UPDATE IS 'Журнал изменений таблицы listing'; -COMMENT ON COLUMN LISTING_UPDATE.LISTING_ID IS 'Идентификатор записи в таблице LISTING'; -COMMENT ON COLUMN LISTING_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN LISTING_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of listing - Листинг инструментов +CREATE TABLE IF NOT EXISTS LISTING_HISTORY(LISTING_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, SECURITY_ID bigint, LOT_SIZE numeric(72,2), MARKET_ID bigint, SYMBOL_CODE varchar(255), SYMBOL_NAME varchar(255), TRADING_CURRENCY char(4), WORKFLOW_STATUS char(4)); +COMMENT ON TABLE LISTING_HISTORY IS 'История изменений таблицы listing'; +COMMENT ON COLUMN LISTING_HISTORY.LISTING_ID IS 'Идентификатор записи в таблице LISTING'; +COMMENT ON COLUMN LISTING_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN LISTING_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN LISTING_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN LISTING_HISTORY.ID IS 'Идентификатор записи'; -COMMENT ON COLUMN LISTING_UPDATE.CREATED_AT IS 'Дата и время создания записи'; +COMMENT ON COLUMN LISTING_HISTORY.CREATED_AT IS 'Дата и время создания записи'; -COMMENT ON COLUMN LISTING_UPDATE.UPDATED_AT IS 'Дата и время изменения записи'; +COMMENT ON COLUMN LISTING_HISTORY.UPDATED_AT IS 'Дата и время изменения записи'; -COMMENT ON COLUMN LISTING_UPDATE.SECURITY_ID IS 'Идентификатор инструмента (linked to security)'; +COMMENT ON COLUMN LISTING_HISTORY.SECURITY_ID IS 'Идентификатор инструмента (linked to security)'; -COMMENT ON COLUMN LISTING_UPDATE.LOT_SIZE IS 'Размер лота'; +COMMENT ON COLUMN LISTING_HISTORY.LOT_SIZE IS 'Размер лота'; -COMMENT ON COLUMN LISTING_UPDATE.MARKET_ID IS 'Идентификатор торговой площадки (linked to market)'; +COMMENT ON COLUMN LISTING_HISTORY.MARKET_ID IS 'Идентификатор торговой площадки (linked to market)'; -COMMENT ON COLUMN LISTING_UPDATE.SYMBOL_CODE IS 'Код инструмента на торговой площадке'; +COMMENT ON COLUMN LISTING_HISTORY.SYMBOL_CODE IS 'Код инструмента на торговой площадке'; -COMMENT ON COLUMN LISTING_UPDATE.SYMBOL_NAME IS 'Название инструмента на торговой площадке'; +COMMENT ON COLUMN LISTING_HISTORY.SYMBOL_NAME IS 'Название инструмента на торговой площадке'; -COMMENT ON COLUMN LISTING_UPDATE.TRADING_CURRENCY IS 'Идентификатор кода валюты расчета (linked to currency)'; +COMMENT ON COLUMN LISTING_HISTORY.TRADING_CURRENCY IS 'Идентификатор кода валюты расчета (linked to currency)'; -COMMENT ON COLUMN LISTING_UPDATE.WORKFLOW_STATUS IS 'Идентификатор статуса листинга в системе (linked to workflowStatus)'; +COMMENT ON COLUMN LISTING_HISTORY.WORKFLOW_STATUS IS 'Идентификатор статуса листинга в системе (linked to workflowStatus)'; -- market - Торговые площадки CREATE TABLE IF NOT EXISTS MARKET(ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, DESCRIPTION varchar(255), EXCHANGE_ID bigint, NAME varchar(255), CODE char(4), SETTLEMENT_CURRENCY char(4), SECTOR char(4)); @@ -1002,30 +994,30 @@ COMMENT ON COLUMN MARKET.SETTLEMENT_CURRENCY IS 'Валютный код рас COMMENT ON COLUMN MARKET.SECTOR IS 'Идентификатор секции (linked to sector)'; --- Update log of market - Торговые площадки -CREATE TABLE IF NOT EXISTS MARKET_UPDATE(MARKET_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, DESCRIPTION varchar(255), EXCHANGE_ID bigint, NAME varchar(255), CODE char(4), SETTLEMENT_CURRENCY char(4), SECTOR char(4)); -COMMENT ON TABLE MARKET_UPDATE IS 'Журнал изменений таблицы market'; -COMMENT ON COLUMN MARKET_UPDATE.MARKET_ID IS 'Идентификатор записи в таблице MARKET'; -COMMENT ON COLUMN MARKET_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN MARKET_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of market - Торговые площадки +CREATE TABLE IF NOT EXISTS MARKET_HISTORY(MARKET_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, CREATED_AT timestamp, UPDATED_AT timestamp, DESCRIPTION varchar(255), EXCHANGE_ID bigint, NAME varchar(255), CODE char(4), SETTLEMENT_CURRENCY char(4), SECTOR char(4)); +COMMENT ON TABLE MARKET_HISTORY IS 'История изменений таблицы market'; +COMMENT ON COLUMN MARKET_HISTORY.MARKET_ID IS 'Идентификатор записи в таблице MARKET'; +COMMENT ON COLUMN MARKET_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN MARKET_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN MARKET_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN MARKET_HISTORY.ID IS 'Идентификатор записи'; -COMMENT ON COLUMN MARKET_UPDATE.CREATED_AT IS 'Дата и время создания записи'; +COMMENT ON COLUMN MARKET_HISTORY.CREATED_AT IS 'Дата и время создания записи'; -COMMENT ON COLUMN MARKET_UPDATE.UPDATED_AT IS 'Дата и время изменения записи'; +COMMENT ON COLUMN MARKET_HISTORY.UPDATED_AT IS 'Дата и время изменения записи'; -COMMENT ON COLUMN MARKET_UPDATE.DESCRIPTION IS 'Описание'; +COMMENT ON COLUMN MARKET_HISTORY.DESCRIPTION IS 'Описание'; -COMMENT ON COLUMN MARKET_UPDATE.EXCHANGE_ID IS 'Идентификатор площадки (linked to company)'; +COMMENT ON COLUMN MARKET_HISTORY.EXCHANGE_ID IS 'Идентификатор площадки (linked to company)'; -COMMENT ON COLUMN MARKET_UPDATE.NAME IS 'Наименование'; +COMMENT ON COLUMN MARKET_HISTORY.NAME IS 'Наименование'; -COMMENT ON COLUMN MARKET_UPDATE.CODE IS 'Режим'; +COMMENT ON COLUMN MARKET_HISTORY.CODE IS 'Режим'; -COMMENT ON COLUMN MARKET_UPDATE.SETTLEMENT_CURRENCY IS 'Валютный код расчетов (linked to currency)'; +COMMENT ON COLUMN MARKET_HISTORY.SETTLEMENT_CURRENCY IS 'Валютный код расчетов (linked to currency)'; -COMMENT ON COLUMN MARKET_UPDATE.SECTOR IS 'Идентификатор секции (linked to sector)'; +COMMENT ON COLUMN MARKET_HISTORY.SECTOR IS 'Идентификатор секции (linked to sector)'; -- accountBalance - Информация об остатках ден. средств CREATE TABLE IF NOT EXISTS ACCOUNT_BALANCE(ID bigint PRIMARY KEY, COMPANY_ID bigint, CREATED_AT timestamp, UPDATED_AT timestamp, ACCOUNT_ID bigint, ACCOUNT_TYPE bigint, ACCOUNT bigint, OPEN_BALANCE_AMOUNT numeric(72,18), START_BALANCE_AMOUNT numeric(72,18), CLOSE_BALANCE_AMOUNT numeric(72,18), TRADE_BALANCE_AMOUNT numeric(72,18), FREE_BALANCE_AMOUNT numeric(72,18), CHANGE_BALANCE_AMOUNT numeric(72,18), CREDIT_AMOUNT numeric(72,18), DEBIT_AMOUNT numeric(72,18), BALANCE_AMOUNT numeric(72,18), BALANCE_ACCOUNT_TYPE char(4), CLEARING_DATE date, CURRENCY_CODE char(4), TRADING_CODE varchar(255), SHORT_NAME varchar(255), FULL_NAME varchar(255)); @@ -1076,59 +1068,59 @@ COMMENT ON COLUMN ACCOUNT_BALANCE.SHORT_NAME IS 'Короткое наимено COMMENT ON COLUMN ACCOUNT_BALANCE.FULL_NAME IS 'Полное наименование Участника (linked to company)'; --- Update log of accountBalance - Информация об остатках ден. средств -CREATE TABLE IF NOT EXISTS ACCOUNT_BALANCE_UPDATE(ACCOUNT_BALANCE_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, COMPANY_ID bigint, CREATED_AT timestamp, UPDATED_AT timestamp, ACCOUNT_ID bigint, ACCOUNT_TYPE bigint, ACCOUNT bigint, OPEN_BALANCE_AMOUNT numeric(72,18), START_BALANCE_AMOUNT numeric(72,18), CLOSE_BALANCE_AMOUNT numeric(72,18), TRADE_BALANCE_AMOUNT numeric(72,18), FREE_BALANCE_AMOUNT numeric(72,18), CHANGE_BALANCE_AMOUNT numeric(72,18), CREDIT_AMOUNT numeric(72,18), DEBIT_AMOUNT numeric(72,18), BALANCE_AMOUNT numeric(72,18), BALANCE_ACCOUNT_TYPE char(4), CLEARING_DATE date, CURRENCY_CODE char(4), TRADING_CODE varchar(255), SHORT_NAME varchar(255), FULL_NAME varchar(255)); -COMMENT ON TABLE ACCOUNT_BALANCE_UPDATE IS 'Журнал изменений таблицы accountBalance'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.ACCOUNT_BALANCE_ID IS 'Идентификатор записи в таблице ACCOUNT_BALANCE'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of accountBalance - Информация об остатках ден. средств +CREATE TABLE IF NOT EXISTS ACCOUNT_BALANCE_HISTORY(ACCOUNT_BALANCE_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, COMPANY_ID bigint, CREATED_AT timestamp, UPDATED_AT timestamp, ACCOUNT_ID bigint, ACCOUNT_TYPE bigint, ACCOUNT bigint, OPEN_BALANCE_AMOUNT numeric(72,18), START_BALANCE_AMOUNT numeric(72,18), CLOSE_BALANCE_AMOUNT numeric(72,18), TRADE_BALANCE_AMOUNT numeric(72,18), FREE_BALANCE_AMOUNT numeric(72,18), CHANGE_BALANCE_AMOUNT numeric(72,18), CREDIT_AMOUNT numeric(72,18), DEBIT_AMOUNT numeric(72,18), BALANCE_AMOUNT numeric(72,18), BALANCE_ACCOUNT_TYPE char(4), CLEARING_DATE date, CURRENCY_CODE char(4), TRADING_CODE varchar(255), SHORT_NAME varchar(255), FULL_NAME varchar(255)); +COMMENT ON TABLE ACCOUNT_BALANCE_HISTORY IS 'История изменений таблицы accountBalance'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.ACCOUNT_BALANCE_ID IS 'Идентификатор записи в таблице ACCOUNT_BALANCE'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.ID IS 'Идентификатор записи'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.ID IS 'Идентификатор записи'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.COMPANY_ID IS 'Идентификатор участника (linked to company)'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.COMPANY_ID IS 'Идентификатор участника (linked to company)'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.CREATED_AT IS 'Дата и время создания записи'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.CREATED_AT IS 'Дата и время создания записи'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.UPDATED_AT IS 'Дата и время изменения записи'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.UPDATED_AT IS 'Дата и время изменения записи'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.ACCOUNT_ID IS 'Идентификатор счета (linked to account)'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.ACCOUNT_ID IS 'Идентификатор счета (linked to account)'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.ACCOUNT_TYPE IS 'Тип счета (linked to account)'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.ACCOUNT_TYPE IS 'Тип счета (linked to account)'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.ACCOUNT IS 'Счет (linked to account)'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.ACCOUNT IS 'Счет (linked to account)'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.OPEN_BALANCE_AMOUNT IS 'Начальная сумма после расчетной организации'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.OPEN_BALANCE_AMOUNT IS 'Начальная сумма после расчетной организации'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.START_BALANCE_AMOUNT IS 'Начальная сумма остатков ден. средств на начало работы'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.START_BALANCE_AMOUNT IS 'Начальная сумма остатков ден. средств на начало работы'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.CLOSE_BALANCE_AMOUNT IS 'Конечная сумма остатков ден. средств на счете'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.CLOSE_BALANCE_AMOUNT IS 'Конечная сумма остатков ден. средств на счете'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.TRADE_BALANCE_AMOUNT IS 'Регистр «Денежные средства Участника клиринга – блокированные»'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.TRADE_BALANCE_AMOUNT IS 'Регистр «Денежные средства Участника клиринга – блокированные»'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.FREE_BALANCE_AMOUNT IS 'Регистр «Денежные средства Участника клиринга – свободные»'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.FREE_BALANCE_AMOUNT IS 'Регистр «Денежные средства Участника клиринга – свободные»'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.CHANGE_BALANCE_AMOUNT IS 'Сумма изменения остатков ден. средств на счете'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.CHANGE_BALANCE_AMOUNT IS 'Сумма изменения остатков ден. средств на счете'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.CREDIT_AMOUNT IS 'Зачисления'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.CREDIT_AMOUNT IS 'Зачисления'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.DEBIT_AMOUNT IS 'Списания'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.DEBIT_AMOUNT IS 'Списания'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.BALANCE_AMOUNT IS 'Денежные средства Участника клиринга, зарезервированные на торги'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.BALANCE_AMOUNT IS 'Денежные средства Участника клиринга, зарезервированные на торги'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.BALANCE_ACCOUNT_TYPE IS 'Тип баланса (linked to balanceAccountType)'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.BALANCE_ACCOUNT_TYPE IS 'Тип баланса (linked to balanceAccountType)'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.CLEARING_DATE IS 'Дата расчета'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.CLEARING_DATE IS 'Дата расчета'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.CURRENCY_CODE IS 'Код валюты (linked to currency)'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.CURRENCY_CODE IS 'Код валюты (linked to currency)'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.TRADING_CODE IS 'Торговый код Участника (linked to company)'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.TRADING_CODE IS 'Торговый код Участника (linked to company)'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.SHORT_NAME IS 'Короткое наименование Участника (linked to company)'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.SHORT_NAME IS 'Короткое наименование Участника (linked to company)'; -COMMENT ON COLUMN ACCOUNT_BALANCE_UPDATE.FULL_NAME IS 'Полное наименование Участника (linked to company)'; +COMMENT ON COLUMN ACCOUNT_BALANCE_HISTORY.FULL_NAME IS 'Полное наименование Участника (linked to company)'; -- managementJournal - Журнал монитора и контроля -CREATE TABLE IF NOT EXISTS MANAGEMENT_JOURNAL(ID bigint PRIMARY KEY, COMPANY_ID bigint, USER_ID bigint, MANAGEMENT_JOURNAL_TYPE_ID bigint, MANAGEMENT_JOURNAL_PURPOSE_ID bigint, STATUS char(4), TEXT varchar(4096), CHANGE_ACCESS_SIGN char(4), CHANGE_DATA_SIGN char(4), EVENT_DATE timestamp, UPDATED_AT timestamp, CREATED_AT timestamp); +CREATE TABLE IF NOT EXISTS MANAGEMENT_JOURNAL(ID bigint PRIMARY KEY, COMPANY_ID bigint, USER_ID bigint, MANAGEMENT_JOURNAL_TYPE_ID bigint, MANAGEMENT_JOURNAL_PURPOSE_ID bigint, STATUS char(4), TEXT varchar(4096), CHANGE_ACCESS_SIGN char(4), CHANGE_DATA_SIGN char(4), EVENT_DATE timestamp, UPDATED_AT timestamp, CREATED_AT timestamp, SUBSCRIPTION , ACTIONS ); COMMENT ON TABLE MANAGEMENT_JOURNAL IS 'Журнал монитора и контроля'; COMMENT ON COLUMN MANAGEMENT_JOURNAL.ID IS 'Идентификатор'; @@ -1155,9 +1147,12 @@ COMMENT ON COLUMN MANAGEMENT_JOURNAL.UPDATED_AT IS 'Изменено'; COMMENT ON COLUMN MANAGEMENT_JOURNAL.CREATED_AT IS 'Создано'; +COMMENT ON COLUMN MANAGEMENT_JOURNAL.SUBSCRIPTION IS ''; + +COMMENT ON COLUMN MANAGEMENT_JOURNAL.ACTIONS IS ''; -- executionDeposit - Сделки -CREATE TABLE IF NOT EXISTS EXECUTION_DEPOSIT(ID bigint PRIMARY KEY, EXCHANGE_EXECUTION_ID bigint, EXCHANGE_EXECUTION_TIME date, CREATED_AT time, UPDATED_AT time, TRADING_DATE date, ACCOUNT_ID bigint, MARKET_ID bigint, PRICE numeric(72,18), AMOUNT bigint, SIDE_ID bigint, SETTLEMENT_CURRENCY_ID bigint, COMPANY_ID bigint, DURATION bigint, FIRST_LEG_SETTLEMENT_DATE date, SECOND_LEG_SETTLEMENT_DATE date, SECOND_LEG_AMOUNT date, INTEREST_AMOUNT date, SYMBOL_NAME varchar(50), SYMBOL_CODE varchar(20), SECURITIES_DEPOSIT_ID bigint, COUNTER_PARTY_ID bigint, SESSION_ID bigint, COVERAGE_STATUS_ID bigint); +CREATE TABLE IF NOT EXISTS EXECUTION_DEPOSIT(ID bigint PRIMARY KEY, EXCHANGE_EXECUTION_ID bigint, EXCHANGE_EXECUTION_TIME date, CREATED_AT time, UPDATED_AT time, TRADING_DATE date, ACCOUNT_ID bigint, MARKET_ID bigint, PRICE numeric(72,18), AMOUNT bigint, SIDE_ID bigint, SETTLEMENT_CURRENCY_ID bigint, COMPANY_ID bigint, DURATION bigint, FIRST_LEG_SETTLEMENT_DATE date, SECOND_LEG_SETTLEMENT_DATE date, SECOND_LEG_AMOUNT date, INTEREST_AMOUNT date, SYMBOL_NAME varchar(50), SYMBOL_CODE varchar(20), SECURITIES_DEPOSIT_ID bigint, COUNTER_PARTY_ID bigint, SESSION_ID bigint, COVERAGE_STATUS_ID bigint, SUBSCRIPTION ); COMMENT ON TABLE EXECUTION_DEPOSIT IS 'Сделки'; COMMENT ON COLUMN EXECUTION_DEPOSIT.ID IS 'ID записи'; @@ -1208,9 +1203,10 @@ COMMENT ON COLUMN EXECUTION_DEPOSIT.SESSION_ID IS 'Сессия (linked to money COMMENT ON COLUMN EXECUTION_DEPOSIT.COVERAGE_STATUS_ID IS 'Cтатус достаточности обеспечения (linked to allowed)'; +COMMENT ON COLUMN EXECUTION_DEPOSIT.SUBSCRIPTION IS ''; -- executionDepositRegister - Реестр сделок -CREATE TABLE IF NOT EXISTS EXECUTION_DEPOSIT_REGISTER(ID bigint PRIMARY KEY, EXCHANGE_EXECUTION_ID bigint, EXCHANGE_EXECUTION_TIME date, CREATED_AT time, UPDATED_AT time, TRADING_DATE date, CLEARING_DATE date, ACCOUNT_ID bigint, MARKET_ID bigint, PRICE numeric(72,18), AMOUNT bigint, SIDE_ID bigint, SETTLEMENT_CURRENCY_ID bigint, COMPANY_ID bigint, FIRST_LEG_SETTLEMENT_DATE date, SECOND_LEG_SETTLEMENT_DATE date, SYMBOL_NAME varchar(50), SYMBOL_CODE varchar(20), SECURITIES_DEPOSIT_ID bigint, COUNTER_PARTY_ID bigint, COVERAGE_STATUS_ID bigint, SESSION_ID bigint); +CREATE TABLE IF NOT EXISTS EXECUTION_DEPOSIT_REGISTER(ID bigint PRIMARY KEY, EXCHANGE_EXECUTION_ID bigint, EXCHANGE_EXECUTION_TIME date, CREATED_AT time, UPDATED_AT time, TRADING_DATE date, CLEARING_DATE date, ACCOUNT_ID bigint, MARKET_ID bigint, PRICE numeric(72,18), AMOUNT bigint, SIDE_ID bigint, SETTLEMENT_CURRENCY_ID bigint, COMPANY_ID bigint, FIRST_LEG_SETTLEMENT_DATE date, SECOND_LEG_SETTLEMENT_DATE date, SYMBOL_NAME varchar(50), SYMBOL_CODE varchar(20), SECURITIES_DEPOSIT_ID bigint, COUNTER_PARTY_ID bigint, COVERAGE_STATUS_ID bigint, SESSION_ID bigint, SUBSCRIPTION ); COMMENT ON TABLE EXECUTION_DEPOSIT_REGISTER IS 'Реестр сделок'; COMMENT ON COLUMN EXECUTION_DEPOSIT_REGISTER.ID IS 'ID записи'; @@ -1257,6 +1253,7 @@ COMMENT ON COLUMN EXECUTION_DEPOSIT_REGISTER.COVERAGE_STATUS_ID IS 'Cтатус COMMENT ON COLUMN EXECUTION_DEPOSIT_REGISTER.SESSION_ID IS 'Сессия (linked to moneyMarketSession)'; +COMMENT ON COLUMN EXECUTION_DEPOSIT_REGISTER.SUBSCRIPTION IS ''; -- reportRegister - Реестр отчетов CREATE TABLE IF NOT EXISTS REPORT_REGISTER(ID bigint PRIMARY KEY, CREATED_AT time, UPDATED_AT time, CLEARING_DATE date, COMPANY_FULL_NAME varchar(255), CLEARING_CODE varchar(255), SESSION_ID bigint, COMMENT varchar(255), NAME varchar(255), QUANTITY bigint); @@ -1653,32 +1650,32 @@ COMMENT ON COLUMN CHARGE_TARIFF.CREATED_AT IS 'Создано'; COMMENT ON COLUMN CHARGE_TARIFF.UPDATED_AT IS 'Изменено'; --- Update log of chargeTariff - Тарифы комиссий -CREATE TABLE IF NOT EXISTS CHARGE_TARIFF_UPDATE(CHARGE_TARIFF_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, MARKET bigint, CLEARING_MEMBER_CATEGORY char(4), CHARGE_TYPE_ID bigint, CHARGE_RATE numeric(72,18), CURRENCY bigint, VALID_FROM_DATE date, VALID_TO_DATE date, CREATED_AT timestamp, UPDATED_AT timestamp); -COMMENT ON TABLE CHARGE_TARIFF_UPDATE IS 'Журнал изменений таблицы chargeTariff'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.CHARGE_TARIFF_ID IS 'Идентификатор записи в таблице CHARGE_TARIFF'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of chargeTariff - Тарифы комиссий +CREATE TABLE IF NOT EXISTS CHARGE_TARIFF_HISTORY(CHARGE_TARIFF_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, MARKET bigint, CLEARING_MEMBER_CATEGORY char(4), CHARGE_TYPE_ID bigint, CHARGE_RATE numeric(72,18), CURRENCY bigint, VALID_FROM_DATE date, VALID_TO_DATE date, CREATED_AT timestamp, UPDATED_AT timestamp); +COMMENT ON TABLE CHARGE_TARIFF_HISTORY IS 'История изменений таблицы chargeTariff'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.CHARGE_TARIFF_ID IS 'Идентификатор записи в таблице CHARGE_TARIFF'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.ID IS 'Идентификатор'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.ID IS 'Идентификатор'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.MARKET IS 'Секция (linked to market)'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.MARKET IS 'Секция (linked to market)'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.CLEARING_MEMBER_CATEGORY IS 'Категория участника клиринга (linked to clearingCategory)'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.CLEARING_MEMBER_CATEGORY IS 'Категория участника клиринга (linked to clearingCategory)'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.CHARGE_TYPE_ID IS 'Тип комиссии (linked to chargeType)'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.CHARGE_TYPE_ID IS 'Тип комиссии (linked to chargeType)'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.CHARGE_RATE IS 'Ставка комиссионного сбора'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.CHARGE_RATE IS 'Ставка комиссионного сбора'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.CURRENCY IS 'Валюта начисления комиссии (linked to currencyCode)'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.CURRENCY IS 'Валюта начисления комиссии (linked to currencyCode)'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.VALID_FROM_DATE IS 'Дата начала срока действия'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.VALID_FROM_DATE IS 'Дата начала срока действия'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.VALID_TO_DATE IS 'Дата окончания срока действия'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.VALID_TO_DATE IS 'Дата окончания срока действия'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.CREATED_AT IS 'Создано'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.CREATED_AT IS 'Создано'; -COMMENT ON COLUMN CHARGE_TARIFF_UPDATE.UPDATED_AT IS 'Изменено'; +COMMENT ON COLUMN CHARGE_TARIFF_HISTORY.UPDATED_AT IS 'Изменено'; -- individualChargeTariff - Индивидуальные тарифы комиссий для Участника CREATE TABLE IF NOT EXISTS INDIVIDUAL_CHARGE_TARIFF(ID bigint PRIMARY KEY, COMPANY_ID bigint, MARKET bigint, CLEARING_MEMBER_CATEGORY char(4), CHARGE_TYPE_ID bigint, CHARGE_RATE numeric(72,18), CURRENCY bigint, VALID_FROM_DATE date, VALID_TO_DATE date, CREATED_AT timestamp, UPDATED_AT timestamp); @@ -1707,34 +1704,34 @@ COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF.CREATED_AT IS 'Создано'; COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF.UPDATED_AT IS 'Изменено'; --- Update log of individualChargeTariff - Индивидуальные тарифы комиссий для Участника -CREATE TABLE IF NOT EXISTS INDIVIDUAL_CHARGE_TARIFF_UPDATE(INDIVIDUAL_CHARGE_TARIFF_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, COMPANY_ID bigint, MARKET bigint, CLEARING_MEMBER_CATEGORY char(4), CHARGE_TYPE_ID bigint, CHARGE_RATE numeric(72,18), CURRENCY bigint, VALID_FROM_DATE date, VALID_TO_DATE date, CREATED_AT timestamp, UPDATED_AT timestamp); -COMMENT ON TABLE INDIVIDUAL_CHARGE_TARIFF_UPDATE IS 'Журнал изменений таблицы individualChargeTariff'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.INDIVIDUAL_CHARGE_TARIFF_ID IS 'Идентификатор записи в таблице INDIVIDUAL_CHARGE_TARIFF'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.EVENT_TIME IS 'Дата и время изменения'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.EVENT_USER_ID IS 'Инициатор изменения'; +-- History log of individualChargeTariff - Индивидуальные тарифы комиссий для Участника +CREATE TABLE IF NOT EXISTS INDIVIDUAL_CHARGE_TARIFF_HISTORY(INDIVIDUAL_CHARGE_TARIFF_ID BIGINT NOT NULL, EVENT_TIME timestamp, EVENT_USER_ID BIGINT, ID bigint PRIMARY KEY, COMPANY_ID bigint, MARKET bigint, CLEARING_MEMBER_CATEGORY char(4), CHARGE_TYPE_ID bigint, CHARGE_RATE numeric(72,18), CURRENCY bigint, VALID_FROM_DATE date, VALID_TO_DATE date, CREATED_AT timestamp, UPDATED_AT timestamp); +COMMENT ON TABLE INDIVIDUAL_CHARGE_TARIFF_HISTORY IS 'История изменений таблицы individualChargeTariff'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.INDIVIDUAL_CHARGE_TARIFF_ID IS 'Идентификатор записи в таблице INDIVIDUAL_CHARGE_TARIFF'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.EVENT_TIME IS 'Дата и время изменения'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.EVENT_USER_ID IS 'Инициатор изменения'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.ID IS 'Идентификатор'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.ID IS 'Идентификатор'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.COMPANY_ID IS 'Участник (linked to company)'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.COMPANY_ID IS 'Участник (linked to company)'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.MARKET IS 'Секция (linked to market)'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.MARKET IS 'Секция (linked to market)'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.CLEARING_MEMBER_CATEGORY IS 'Категория участника клиринга (linked to clearingCategory)'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.CLEARING_MEMBER_CATEGORY IS 'Категория участника клиринга (linked to clearingCategory)'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.CHARGE_TYPE_ID IS 'Тип комиссии (linked to chargeType)'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.CHARGE_TYPE_ID IS 'Тип комиссии (linked to chargeType)'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.CHARGE_RATE IS 'Ставка комиссионного сбора'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.CHARGE_RATE IS 'Ставка комиссионного сбора'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.CURRENCY IS 'Валюта начисления комиссии (linked to currencyCode)'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.CURRENCY IS 'Валюта начисления комиссии (linked to currencyCode)'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.VALID_FROM_DATE IS 'Дата начала срока действия'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.VALID_FROM_DATE IS 'Дата начала срока действия'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.VALID_TO_DATE IS 'Дата окончания срока действия'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.VALID_TO_DATE IS 'Дата окончания срока действия'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.CREATED_AT IS 'Создано'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.CREATED_AT IS 'Создано'; -COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_UPDATE.UPDATED_AT IS 'Изменено'; +COMMENT ON COLUMN INDIVIDUAL_CHARGE_TARIFF_HISTORY.UPDATED_AT IS 'Изменено'; -- companyTariff - Тарифы комиссий в разрезе Участника CREATE TABLE IF NOT EXISTS COMPANY_TARIFF(ID bigint PRIMARY KEY, MARKET bigint, CLEARING_MEMBER_CATEGORY char(4), FULL_NAME varchar(255), CONTRACT varchar(255), CHARGE_TYPE_ID bigint, CHARGE_RATE numeric(72,18), CURRENCY bigint, VALID_FROM_DATE date, VALID_TO_DATE date, CREATED_AT timestamp, UPDATED_AT timestamp, COMPANY_ID bigint); diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/ErrorTextMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/ErrorTextMapStore.java new file mode 100644 index 000000000..d17a8c823 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/ErrorTextMapStore.java @@ -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 com.moex.spicex.Static.ErrorText; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.clearing.imdg.utils.DbUtilsHelper; +import ru.spcex.clearing.imdg.utils.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.*; + +@Component +public class ErrorTextMapStore extends TemplateMapStore { + + public ErrorTextMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_ErrorText; + } + + @Override + public String getTableName() { + return "ERROR_TEXT"; + } + + @Override + public String[] getFields() { + return new String[]{ + "ID", "CREATED_AT", "UPDATED_AT", "ERROR_CODE", "TEXT", "USER_ID", "CLEARING_DATE" + }; + } + + @Override + public ErrorText objectReader(ResultSet resultSet) throws SQLException { + ErrorText object = new ErrorText(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCreatedAt(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdatedAt(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setErrorCode(resultSet.getObject("ERROR_CODE", String.class)); + object.setText(resultSet.getObject("TEXT", String.class)); + object.setUserId(resultSet.getObject("USER_ID", Long.class)); + object.setClearingDate(getInstantFromTimestamp(resultSet, "CLEARING_DATE")); + return object; + } + + @Override + public Object[] objectToField(ErrorText object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.fromInstant(object.getCreatedAt()), + TimeUtil.fromInstant(object.getUpdatedAt()), + object.getErrorCode(), + object.getText(), + object.getUserId(), + TimeUtil.fromInstant(object.getClearingDate()) + }; + return args; + } + +} \ No newline at end of file diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/StatementMapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/StatementMapStore.java new file mode 100644 index 000000000..363c4eccb --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/businessobject/StatementMapStore.java @@ -0,0 +1,90 @@ +package ru.spcex.clearing.imdg.businessobject; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import com.moex.platform.classes.TransactionData.Execution.LiabilitiesClaimsAssets; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.clearing.imdg.utils.DbUtilsHelper; +import ru.spcex.clearing.imdg.utils.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.*; + +@Component +public class StatementMapStore extends TemplateMapStore { + + public StatementMapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_Statement; + } + + @Override + public String getTableName() { + return "STATEMENT"; + } + + @Override + public String[] getFields() { + return new String[]{ + "ID", "ADDRESSEE_ID", "SENDER_ID", "CREATED_AT", "UPDATED_AT", "CLEARING_DATE", "STATEMENT_TYPE_ID", "COMMENT", "ACCOUNT_ID", "ACCOUNT", "IN_OUT_DIRECTION", "SETTLEMENT_DATE", "AMOUNT", "CASH_MOVEMENT_CURRENCY_CODE", "STATUS", "ERROR_CODE", "ERROR_TEXT", "IN_S_DF_ID", "OUT_S_DF_ID" + }; + } + + @Override + public Statement objectReader(ResultSet resultSet) throws SQLException { + Statement object = new Statement(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setAddresseeId(resultSet.getObject("ADDRESSEE_ID", Long.class)); + object.setSenderId(resultSet.getObject("SENDER_ID", Long.class)); + object.setCreatedAt(getInstantFromTimestamp(resultSet, "CREATED_AT")); + object.setUpdatedAt(getInstantFromTimestamp(resultSet, "UPDATED_AT")); + object.setClearingDate(getInstantFromTimestamp(resultSet, "CLEARING_DATE")); + object.setStatementTypeId(resultSet.getObject("STATEMENT_TYPE_ID", Long.class)); + object.setComment(resultSet.getObject("COMMENT", String.class)); + object.setAccountId(resultSet.getObject("ACCOUNT_ID", Long.class)); + object.setAccount(resultSet.getObject("ACCOUNT", Long.class)); + object.setInOutDirection(resultSet.getObject("IN_OUT_DIRECTION", Long.class)); + object.setSettlementDate(getInstantFromTimestamp(resultSet, "SETTLEMENT_DATE")); + object.setAmount(resultSet.getObject("AMOUNT", BigDecimal.class)); + object.setCashMovementCurrencyCode(resultSet.getObject("CASH_MOVEMENT_CURRENCY_CODE", String.class)); + object.setStatus(resultSet.getObject("STATUS", String.class)); + object.setErrorCode(resultSet.getObject("ERROR_CODE", String.class)); + object.setErrorText(resultSet.getObject("ERROR_TEXT", String.class)); + object.setInSDfId(resultSet.getObject("IN_S_DF_ID", Long.class)); + object.setOutSDfId(resultSet.getObject("OUT_S_DF_ID", Long.class)); + return object; + } + + @Override + public Object[] objectToField(Statement object) { + Object[] args = new Object[]{ + object.getId(), + object.getAddresseeId(), + object.getSenderId(), + TimeUtil.fromInstant(object.getCreatedAt()), + TimeUtil.fromInstant(object.getUpdatedAt()), + TimeUtil.fromInstant(object.getClearingDate()), + object.getStatementTypeId(), + object.getComment(), + object.getAccountId(), + object.getAccount(), + object.getInOutDirection(), + TimeUtil.fromInstant(object.getSettlementDate()), + object.getAmount(), + object.getCashMovementCurrencyCode(), + object.getStatus(), + object.getErrorCode(), + object.getErrorText(), + object.getInSDfId(), + object.getOutSDfId() + }; + return args; + } + +} \ No newline at end of file diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/RequestDf03MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/RequestDf03MapStore.java new file mode 100644 index 000000000..980fcf52b --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/RequestDf03MapStore.java @@ -0,0 +1,152 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import com.spicex.Static.; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.clearing.imdg.utils.DbUtilsHelper; +import ru.spcex.clearing.imdg.utils.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.*; + +@Component +public class RequestDf03MapStore extends TemplateMapStore { + + public RequestDf03MapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_RequestDf03; + } + + @Override + public String getTableName() { + return "REQUEST_DF03"; + } + + @Override + public String[] getFields() { + return new String[]{ + "ID", "REQUEST_DATE", "RESPONSE_DATE", "DOC_TYPE", "DOCNM_REF", "DOCNMPREV", "PRIORITY", "SBANKCODE", "C_ACC_DEB", "SBANKNAM1", "SBANKNAM2", "SBANKNAM3", "SBANKNAM4", "SBANKNAM5", "RBANKCODE", "C_ACC_CRED", "RBANKNAM1", "RBANKNAM2", "RBANKNAM3", "RBANKNAM4", "RBANKNAM5", "PAY_DATE", "EXT_DATE", "PAY_VAL", "SUM_DEB", "SCLIENTN1", "SCLIENTN2", "SCLIENTN3", "SCLIENTN4", "SC_CODE", "ACC_DEB", "RCLIENTN1", "RCLIENTN2", "RCLIENTN3", "RCLIENTN4", "ACC_KR_1", "ACC_KR_2", "SP_CODE", "SPECIF_1", "SPECIF_2", "SPECIF_3", "SPECIF_4", "SPECIF_5", "SPECIF_6", "SEND_TYPE", "SERVDATE", "DOC_RESULT", "SEND_RESULT", "ERROR_TEXT", "RESPONSE_RESULT" + }; + } + + @Override + public RequestDf03 objectReader(ResultSet resultSet) throws SQLException { + RequestDf03 object = new RequestDf03(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setRequestDate(getInstantFromTimestamp(resultSet, "REQUEST_DATE")); + object.setResponseDate(getInstantFromTimestamp(resultSet, "RESPONSE_DATE")); + object.setDocType(resultSet.getObject("DOC_TYPE", String.class)); + object.setDocnmRef(resultSet.getObject("DOCNM_REF", String.class)); + object.setDocnmprev(resultSet.getObject("DOCNMPREV", String.class)); + object.setPriority(resultSet.getObject("PRIORITY", String.class)); + object.setSbankcode(resultSet.getObject("SBANKCODE", String.class)); + object.setCAccDeb(resultSet.getObject("C_ACC_DEB", String.class)); + object.setSbanknam1(resultSet.getObject("SBANKNAM1", String.class)); + object.setSbanknam2(resultSet.getObject("SBANKNAM2", String.class)); + object.setSbanknam3(resultSet.getObject("SBANKNAM3", String.class)); + object.setSbanknam4(resultSet.getObject("SBANKNAM4", String.class)); + object.setSbanknam5(resultSet.getObject("SBANKNAM5", String.class)); + object.setRbankcode(resultSet.getObject("RBANKCODE", String.class)); + object.setCAccCred(resultSet.getObject("C_ACC_CRED", String.class)); + object.setRbanknam1(resultSet.getObject("RBANKNAM1", String.class)); + object.setRbanknam2(resultSet.getObject("RBANKNAM2", String.class)); + object.setRbanknam3(resultSet.getObject("RBANKNAM3", String.class)); + object.setRbanknam4(resultSet.getObject("RBANKNAM4", String.class)); + object.setRbanknam5(resultSet.getObject("RBANKNAM5", String.class)); + object.setPayDate(getInstantFromTimestamp(resultSet, "PAY_DATE")); + object.setExtDate(resultSet.getObject("EXT_DATE", String.class)); + object.setPayVal(resultSet.getObject("PAY_VAL", String.class)); + object.setSumDeb(resultSet.getObject("SUM_DEB", BigDecimal.class)); + object.setSclientn1(resultSet.getObject("SCLIENTN1", String.class)); + object.setSclientn2(resultSet.getObject("SCLIENTN2", String.class)); + object.setSclientn3(resultSet.getObject("SCLIENTN3", String.class)); + object.setSclientn4(resultSet.getObject("SCLIENTN4", String.class)); + object.setScCode(resultSet.getObject("SC_CODE", String.class)); + object.setAccDeb(resultSet.getObject("ACC_DEB", String.class)); + object.setRclientn1(resultSet.getObject("RCLIENTN1", String.class)); + object.setRclientn2(resultSet.getObject("RCLIENTN2", String.class)); + object.setRclientn3(resultSet.getObject("RCLIENTN3", String.class)); + object.setRclientn4(resultSet.getObject("RCLIENTN4", String.class)); + object.setAccKr_1(resultSet.getObject("ACC_KR_1", String.class)); + object.setAccKr_2(resultSet.getObject("ACC_KR_2", String.class)); + object.setSpCode(resultSet.getObject("SP_CODE", String.class)); + object.setSpecif_1(resultSet.getObject("SPECIF_1", String.class)); + object.setSpecif_2(resultSet.getObject("SPECIF_2", String.class)); + object.setSpecif_3(resultSet.getObject("SPECIF_3", String.class)); + object.setSpecif_4(resultSet.getObject("SPECIF_4", String.class)); + object.setSpecif_5(resultSet.getObject("SPECIF_5", String.class)); + object.setSpecif_6(resultSet.getObject("SPECIF_6", String.class)); + object.setSendType(resultSet.getObject("SEND_TYPE", String.class)); + object.setServdate(resultSet.getObject("SERVDATE", String.class)); + object.setDocResult(resultSet.getObject("DOC_RESULT", String.class)); + object.setSendResult(resultSet.getObject("SEND_RESULT", String.class)); + object.setErrorText(resultSet.getObject("ERROR_TEXT", String.class)); + object.setResponseResult(resultSet.getObject("RESPONSE_RESULT", String.class)); + return object; + } + + @Override + public Object[] objectToField(RequestDf03 object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.fromInstant(object.getRequestDate()), + TimeUtil.fromInstant(object.getResponseDate()), + object.getDocType(), + object.getDocnmRef(), + object.getDocnmprev(), + object.getPriority(), + object.getSbankcode(), + object.getCAccDeb(), + object.getSbanknam1(), + object.getSbanknam2(), + object.getSbanknam3(), + object.getSbanknam4(), + object.getSbanknam5(), + object.getRbankcode(), + object.getCAccCred(), + object.getRbanknam1(), + object.getRbanknam2(), + object.getRbanknam3(), + object.getRbanknam4(), + object.getRbanknam5(), + TimeUtil.fromInstant(object.getPayDate()), + object.getExtDate(), + object.getPayVal(), + object.getSumDeb(), + object.getSclientn1(), + object.getSclientn2(), + object.getSclientn3(), + object.getSclientn4(), + object.getScCode(), + object.getAccDeb(), + object.getRclientn1(), + object.getRclientn2(), + object.getRclientn3(), + object.getRclientn4(), + object.getAccKr_1(), + object.getAccKr_2(), + object.getSpCode(), + object.getSpecif_1(), + object.getSpecif_2(), + object.getSpecif_3(), + object.getSpecif_4(), + object.getSpecif_5(), + object.getSpecif_6(), + object.getSendType(), + object.getServdate(), + object.getDocResult(), + object.getSendResult(), + object.getErrorText(), + object.getResponseResult() + }; + return args; + } + +} \ No newline at end of file diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/RequestDf05MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/RequestDf05MapStore.java new file mode 100644 index 000000000..e74f6a90e --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/RequestDf05MapStore.java @@ -0,0 +1,68 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import com.spicex.Static.; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.clearing.imdg.utils.DbUtilsHelper; +import ru.spcex.clearing.imdg.utils.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.*; + +@Component +public class RequestDf05MapStore extends TemplateMapStore { + + public RequestDf05MapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_RequestDf05; + } + + @Override + public String getTableName() { + return "REQUEST_DF05"; + } + + @Override + public String[] getFields() { + return new String[]{ + "ID", "TP", "DT", "TM", "PR", "FILE_NAME", "GENERATION_TIME", "GENERATION_ID" + }; + } + + @Override + public RequestDf05 objectReader(ResultSet resultSet) throws SQLException { + RequestDf05 object = new RequestDf05(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setTp(resultSet.getObject("TP", BigDecimal.class)); + object.setDt(getInstantFromTimestamp(resultSet, "DT")); + object.setTm(getInstantFromTimestamp(resultSet, "TM")); + object.setPr(resultSet.getObject("PR", String.class)); + object.setFileName(resultSet.getObject("FILE_NAME", String.class)); + object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME")); + object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class)); + return object; + } + + @Override + public Object[] objectToField(RequestDf05 object) { + Object[] args = new Object[]{ + object.getId(), + object.getTp(), + TimeUtil.fromInstant(object.getDt()), + TimeUtil.fromInstant(object.getTm()), + object.getPr(), + object.getFileName(), + TimeUtil.fromInstant(object.getGenerationTime()), + object.getGenerationId() + }; + return args; + } + +} \ No newline at end of file diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/RequestDf18MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/RequestDf18MapStore.java new file mode 100644 index 000000000..87b2de98d --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/RequestDf18MapStore.java @@ -0,0 +1,70 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import com.spicex.Static.; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.clearing.imdg.utils.DbUtilsHelper; +import ru.spcex.clearing.imdg.utils.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.*; + +@Component +public class RequestDf18MapStore extends TemplateMapStore { + + public RequestDf18MapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_RequestDf18; + } + + @Override + public String getTableName() { + return "REQUEST_DF18"; + } + + @Override + public String[] getFields() { + return new String[]{ + "ID", "DATETIME", "ACCOUNT", "DEAL", "STATUS", "RESULT", "FILE_NAME", "GENERATION_TIME", "GENERATION_ID" + }; + } + + @Override + public RequestDf18 objectReader(ResultSet resultSet) throws SQLException { + RequestDf18 object = new RequestDf18(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setDatetime(getInstantFromTimestamp(resultSet, "DATETIME")); + object.setAccount(resultSet.getObject("ACCOUNT", String.class)); + object.setDeal(resultSet.getObject("DEAL", String.class)); + object.setStatus(resultSet.getObject("STATUS", BigDecimal.class)); + object.setResult(resultSet.getObject("RESULT", BigDecimal.class)); + object.setFileName(resultSet.getObject("FILE_NAME", String.class)); + object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME")); + object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class)); + return object; + } + + @Override + public Object[] objectToField(RequestDf18 object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.fromInstant(object.getDatetime()), + object.getAccount(), + object.getDeal(), + object.getStatus(), + object.getResult(), + object.getFileName(), + TimeUtil.fromInstant(object.getGenerationTime()), + object.getGenerationId() + }; + return args; + } + +} \ No newline at end of file diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf01MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf01MapStore.java new file mode 100644 index 000000000..03c8ed4b2 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf01MapStore.java @@ -0,0 +1,84 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import com.spicex.Static.; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.clearing.imdg.utils.DbUtilsHelper; +import ru.spcex.clearing.imdg.utils.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.*; + +@Component +public class SDf01MapStore extends TemplateMapStore { + + public SDf01MapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_SDf01; + } + + @Override + public String getTableName() { + return "S_DF01"; + } + + @Override + public String[] getFields() { + return new String[]{ + "ID", "CURR_CODE", "ACCOUNT", "REMAINDER", "DEAL", "ACC_CODE", "DAT", "MARKET", "ACC_NAME", "ACC_TYPE", "SUMENGAGE", "SUMUNBLOCK", "FILE_TYPE", "FILE_NAME", "GENERATION_TIME", "GENERATION_ID" + }; + } + + @Override + public SDf01 objectReader(ResultSet resultSet) throws SQLException { + SDf01 object = new SDf01(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCurr_code(resultSet.getObject("CURR_CODE", String.class)); + object.setAccount(resultSet.getObject("ACCOUNT", String.class)); + object.setRemainder(resultSet.getObject("REMAINDER", String.class)); + object.setDeal(resultSet.getObject("DEAL", String.class)); + object.setAcc_code(resultSet.getObject("ACC_CODE", String.class)); + object.setDat(resultSet.getObject("DAT", String.class)); + object.setMarket(resultSet.getObject("MARKET", String.class)); + object.setAcc_name(resultSet.getObject("ACC_NAME", String.class)); + object.setAcc_type(resultSet.getObject("ACC_TYPE", String.class)); + object.setSumengage(resultSet.getObject("SUMENGAGE", String.class)); + object.setSumunblock(resultSet.getObject("SUMUNBLOCK", String.class)); + object.setFile_type(resultSet.getObject("FILE_TYPE", String.class)); + object.setFileName(resultSet.getObject("FILE_NAME", String.class)); + object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME")); + object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class)); + return object; + } + + @Override + public Object[] objectToField(SDf01 object) { + Object[] args = new Object[]{ + object.getId(), + object.getCurr_code(), + object.getAccount(), + object.getRemainder(), + object.getDeal(), + object.getAcc_code(), + object.getDat(), + object.getMarket(), + object.getAcc_name(), + object.getAcc_type(), + object.getSumengage(), + object.getSumunblock(), + object.getFile_type(), + object.getFileName(), + TimeUtil.fromInstant(object.getGenerationTime()), + object.getGenerationId() + }; + return args; + } + +} diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf02MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf02MapStore.java new file mode 100644 index 000000000..db8dcbeb7 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf02MapStore.java @@ -0,0 +1,86 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import com.spicex.Static.; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.clearing.imdg.utils.DbUtilsHelper; +import ru.spcex.clearing.imdg.utils.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.*; + +@Component +public class SDf02MapStore extends TemplateMapStore { + + public SDf02MapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_SDf02; + } + + @Override + public String getTableName() { + return "S_DF02"; + } + + @Override + public String[] getFields() { + return new String[]{ + "ID", "CURR_CODE", "ACCOUNT", "REMAINDER", "DEAL", "ACC_CODE", "DAT", "MARKET", "ACC_NAME", "ACC_TYPE", "SUMENGAGE", "SUMUNBLOCK", "FILE_TYPE", "RESULT", "FILE_NAME", "GENERATION_TIME", "GENERATION_ID" + }; + } + + @Override + public SDf02 objectReader(ResultSet resultSet) throws SQLException { + SDf02 object = new SDf02(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setCurr_code(resultSet.getObject("CURR_CODE", String.class)); + object.setAccount(resultSet.getObject("ACCOUNT", String.class)); + object.setRemainder(resultSet.getObject("REMAINDER", String.class)); + object.setDeal(resultSet.getObject("DEAL", String.class)); + object.setAcc_code(resultSet.getObject("ACC_CODE", String.class)); + object.setDat(resultSet.getObject("DAT", String.class)); + object.setMarket(resultSet.getObject("MARKET", String.class)); + object.setAcc_name(resultSet.getObject("ACC_NAME", String.class)); + object.setAcc_type(resultSet.getObject("ACC_TYPE", String.class)); + object.setSumengage(resultSet.getObject("SUMENGAGE", String.class)); + object.setSumunblock(resultSet.getObject("SUMUNBLOCK", String.class)); + object.setFile_type(resultSet.getObject("FILE_TYPE", String.class)); + object.setResult(resultSet.getObject("RESULT", String.class)); + object.setFileName(resultSet.getObject("FILE_NAME", String.class)); + object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME")); + object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class)); + return object; + } + + @Override + public Object[] objectToField(SDf02 object) { + Object[] args = new Object[]{ + object.getId(), + object.getCurr_code(), + object.getAccount(), + object.getRemainder(), + object.getDeal(), + object.getAcc_code(), + object.getDat(), + object.getMarket(), + object.getAcc_name(), + object.getAcc_type(), + object.getSumengage(), + object.getSumunblock(), + object.getFile_type(), + object.getResult(), + object.getFileName(), + TimeUtil.fromInstant(object.getGenerationTime()), + object.getGenerationId() + }; + return args; + } + +} \ No newline at end of file diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf08MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf08MapStore.java new file mode 100644 index 000000000..a3b204938 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf08MapStore.java @@ -0,0 +1,64 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import com.spicex.Static.; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.clearing.imdg.utils.DbUtilsHelper; +import ru.spcex.clearing.imdg.utils.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.*; + +@Component +public class SDf08MapStore extends TemplateMapStore { + + public SDf08MapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_SDf08; + } + + @Override + public String getTableName() { + return "S_DF08"; + } + + @Override + public String[] getFields() { + return new String[]{ + "ID", "NUMBER", "DATETIME", "FILE_NAME", "GENERATION_TIME", "GENERATION_ID" + }; + } + + @Override + public SDf08 objectReader(ResultSet resultSet) throws SQLException { + SDf08 object = new SDf08(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setNumber(resultSet.getObject("NUMBER", BigDecimal.class)); + object.setDatetime(resultSet.getObject("DATETIME", BigDecimal.class)); + object.setFileName(resultSet.getObject("FILE_NAME", String.class)); + object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME")); + object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class)); + return object; + } + + @Override + public Object[] objectToField(SDf08 object) { + Object[] args = new Object[]{ + object.getId(), + object.getNumber(), + object.getDatetime(), + object.getFileName(), + TimeUtil.fromInstant(object.getGenerationTime()), + object.getGenerationId() + }; + return args; + } + +} \ No newline at end of file diff --git a/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf16MapStore.java b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf16MapStore.java new file mode 100644 index 000000000..63c756175 --- /dev/null +++ b/clearing-parent/imdg/src/main/java/ru/spcex/clearing/imdg/object/SDf16MapStore.java @@ -0,0 +1,80 @@ +package ru.spcex.clearing.imdg.object; + +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.stereotype.Component; +import ru.spcex.clearing.imdg.IMDGDistributedNames; +import com.spicex.Static.; +import ru.spcex.clearing.imdg.base.TemplateMapStore; +import ru.spcex.clearing.imdg.utils.DbUtilsHelper; +import ru.spcex.clearing.imdg.utils.TimeUtil; + +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.*; + +@Component +public class SDf16MapStore extends TemplateMapStore { + + public SDf16MapStore(JdbcTemplate jdbcTemplate) { + super(jdbcTemplate); + } + + @Override + public String getMapName() { + return IMDGDistributedNames.Map_SDf16; + } + + @Override + public String getTableName() { + return "S_DF16"; + } + + @Override + public String[] getFields() { + return new String[]{ + "ID", "DATE", "ACCOUNT", "SUM", "MARKET", "TYPE", "_I_N_N", "_B_I_C", "_S_P_E_C", "NUMBER", "RESULT_CODE", "FILE_NAME", "GENERATION_TIME", "GENERATION_ID" + }; + } + + @Override + public SDf16 objectReader(ResultSet resultSet) throws SQLException { + SDf16 object = new SDf16(); + object.setId(resultSet.getObject("ID", Long.class)); + object.setDate(getInstantFromTimestamp(resultSet, "DATE")); + object.setAccount(resultSet.getObject("ACCOUNT", String.class)); + object.setSum(resultSet.getObject("SUM", BigDecimal.class)); + object.setMarket(resultSet.getObject("MARKET", String.class)); + object.setType(resultSet.getObject("TYPE", String.class)); + object.setINN(resultSet.getObject("_I_N_N", BigDecimal.class)); + object.setBIC(resultSet.getObject("_B_I_C", BigDecimal.class)); + object.setSPEC(resultSet.getObject("_S_P_E_C", String.class)); + object.setNumber(resultSet.getObject("NUMBER", BigDecimal.class)); + object.setResultCode(resultSet.getObject("RESULT_CODE", String.class)); + object.setFileName(resultSet.getObject("FILE_NAME", String.class)); + object.setGenerationTime(getInstantFromTimestamp(resultSet, "GENERATION_TIME")); + object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class)); + return object; + } + + @Override + public Object[] objectToField(SDf16 object) { + Object[] args = new Object[]{ + object.getId(), + TimeUtil.fromInstant(object.getDate()), + object.getAccount(), + object.getSum(), + object.getMarket(), + object.getType(), + object.getINN(), + object.getBIC(), + object.getSPEC(), + object.getNumber(), + object.getResultCode(), + object.getFileName(), + TimeUtil.fromInstant(object.getGenerationTime()), + object.getGenerationId() + }; + return args; + } + +} \ No newline at end of file