This commit is contained in:
parent
5286104e74
commit
92e59b99cf
6 changed files with 30 additions and 12 deletions
|
|
@ -4,5 +4,5 @@ package ru.clearing.classes;
|
||||||
* В случае любых изменений модуля classes необходимо изменить serialVersionUID++
|
* В случае любых изменений модуля classes необходимо изменить serialVersionUID++
|
||||||
*/
|
*/
|
||||||
public interface ConstSerializable {
|
public interface ConstSerializable {
|
||||||
long serialVersionUID = 293236453422L;
|
long serialVersionUID = 293236453423L;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -22,6 +22,7 @@ public class SDf10 extends SpcexObjectBase implements WithMessageId, WithParentI
|
||||||
private Long generationId;
|
private Long generationId;
|
||||||
private String messageId;
|
private String messageId;
|
||||||
private String parentId;
|
private String parentId;
|
||||||
|
private String workflowStatus;
|
||||||
|
|
||||||
public String getOutDocument() {
|
public String getOutDocument() {
|
||||||
return outDocument;
|
return outDocument;
|
||||||
|
|
@ -87,6 +88,14 @@ public class SDf10 extends SpcexObjectBase implements WithMessageId, WithParentI
|
||||||
this.generationId = generationId;
|
this.generationId = generationId;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public String getWorkflowStatus() {
|
||||||
|
return workflowStatus;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setWorkflowStatus(String workflowStatus) {
|
||||||
|
this.workflowStatus = workflowStatus;
|
||||||
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String getMessageId() {
|
public String getMessageId() {
|
||||||
return messageId;
|
return messageId;
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
-- DB version: 3.23
|
-- DB version: 3.27
|
||||||
/* Dictionaries */
|
/* Dictionaries */
|
||||||
|
|
||||||
-- allowed - Справочник признаков допустимости использования объектов
|
-- allowed - Справочник признаков допустимости использования объектов
|
||||||
|
|
@ -4407,7 +4407,7 @@ GRANT ALL PRIVILEGES ON TABLE S_DF09 TO clearing;
|
||||||
|
|
||||||
-- sDf10 - ДФ-10 Запрос на зачисление/списание ценных бумаг
|
-- sDf10 - ДФ-10 Запрос на зачисление/списание ценных бумаг
|
||||||
DROP TABLE IF EXISTS S_DF10;
|
DROP TABLE IF EXISTS S_DF10;
|
||||||
CREATE TABLE S_DF10(ID bigint PRIMARY KEY, OUT_DOCUMENT varchar, DEPO_CODE varchar, QUANTITY varchar, SECURITY_CODE varchar, CLIENT_NAME varchar, FILE_NAME varchar(255), GENERATION_TIME timestamp, GENERATION_ID bigint, MESSAGE_ID varchar(128), PARENT_ID varchar(128));
|
CREATE TABLE S_DF10(ID bigint PRIMARY KEY, OUT_DOCUMENT varchar, DEPO_CODE varchar, QUANTITY varchar, SECURITY_CODE varchar, CLIENT_NAME varchar, FILE_NAME varchar(255), GENERATION_TIME timestamp, GENERATION_ID bigint, MESSAGE_ID varchar(128), PARENT_ID varchar(128), WORKFLOW_STATUS varchar(4));
|
||||||
COMMENT ON TABLE S_DF10 IS 'ДФ-10 Запрос на зачисление/списание ценных бумаг';
|
COMMENT ON TABLE S_DF10 IS 'ДФ-10 Запрос на зачисление/списание ценных бумаг';
|
||||||
|
|
||||||
COMMENT ON COLUMN S_DF10.ID IS 'Идентификатор записи';
|
COMMENT ON COLUMN S_DF10.ID IS 'Идентификатор записи';
|
||||||
|
|
@ -4432,6 +4432,8 @@ COMMENT ON COLUMN S_DF10.MESSAGE_ID IS 'Номер документа';
|
||||||
|
|
||||||
COMMENT ON COLUMN S_DF10.PARENT_ID IS 'Номер родительского документа';
|
COMMENT ON COLUMN S_DF10.PARENT_ID IS 'Номер родительского документа';
|
||||||
|
|
||||||
|
COMMENT ON COLUMN S_DF10.WORKFLOW_STATUS IS 'Код статуса (linked to workflowStatus)';
|
||||||
|
|
||||||
GRANT ALL PRIVILEGES ON TABLE S_DF10 TO clearing;
|
GRANT ALL PRIVILEGES ON TABLE S_DF10 TO clearing;
|
||||||
|
|
||||||
-- sDf11 - ДФ-11 Ответ на Запрос на зачисление/списание ценных бумаг
|
-- sDf11 - ДФ-11 Ответ на Запрос на зачисление/списание ценных бумаг
|
||||||
|
|
@ -5852,4 +5854,4 @@ GRANT ALL PRIVILEGES ON TABLE ORDER_CURRENCY_HISTORY TO clearing;
|
||||||
|
|
||||||
-- Data types
|
-- Data types
|
||||||
|
|
||||||
INSERT INTO DB_VERSION(ID, VERSION) values (1, '3.26') ON CONFLICT (ID) DO UPDATE SET VERSION = EXCLUDED.VERSION
|
INSERT INTO DB_VERSION(ID, VERSION) values (1, '3.27') ON CONFLICT (ID) DO UPDATE SET VERSION = EXCLUDED.VERSION
|
||||||
|
|
@ -0,0 +1,6 @@
|
||||||
|
-- DB version: 3.26 -> 3.27
|
||||||
|
|
||||||
|
ALTER TABLE S_DF10 ADD COLUMN IF NOT EXISTS WORKFLOW_STATUS VARCHAR(4);
|
||||||
|
COMMENT ON COLUMN S_DF10.WORKFLOW_STATUS IS 'Код статуса (linked to workflowStatus)';
|
||||||
|
|
||||||
|
INSERT INTO DB_VERSION(ID, VERSION) values (1, '3.27') ON CONFLICT (ID) DO UPDATE SET VERSION = EXCLUDED.VERSION;
|
||||||
|
|
@ -1,5 +1,9 @@
|
||||||
package ru.spcex.clearing.imdg.object;
|
package ru.spcex.clearing.imdg.object;
|
||||||
|
|
||||||
|
import java.sql.ResultSet;
|
||||||
|
import java.sql.SQLException;
|
||||||
|
import java.time.LocalDate;
|
||||||
|
import java.util.List;
|
||||||
import org.springframework.jdbc.core.JdbcTemplate;
|
import org.springframework.jdbc.core.JdbcTemplate;
|
||||||
import org.springframework.stereotype.Component;
|
import org.springframework.stereotype.Component;
|
||||||
import ru.clearing.classes.statics.data.sdf.SDf10;
|
import ru.clearing.classes.statics.data.sdf.SDf10;
|
||||||
|
|
@ -8,11 +12,6 @@ import ru.spcex.clearing.imdg.base.TemplateMapStore;
|
||||||
import ru.spcex.platform.utils.log.ExceptionUtils;
|
import ru.spcex.platform.utils.log.ExceptionUtils;
|
||||||
import ru.spcex.platform.utils.time.TimeUtil;
|
import ru.spcex.platform.utils.time.TimeUtil;
|
||||||
|
|
||||||
import java.sql.ResultSet;
|
|
||||||
import java.sql.SQLException;
|
|
||||||
import java.time.LocalDate;
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
@Component
|
@Component
|
||||||
public class SDf10MapStore extends TemplateMapStore<SDf10> {
|
public class SDf10MapStore extends TemplateMapStore<SDf10> {
|
||||||
|
|
||||||
|
|
@ -34,7 +33,7 @@ public class SDf10MapStore extends TemplateMapStore<SDf10> {
|
||||||
public String[] getFields() {
|
public String[] getFields() {
|
||||||
return new String[]{
|
return new String[]{
|
||||||
"ID", "OUT_DOCUMENT", "DEPO_CODE", "QUANTITY", "SECURITY_CODE", "CLIENT_NAME", "FILE_NAME",
|
"ID", "OUT_DOCUMENT", "DEPO_CODE", "QUANTITY", "SECURITY_CODE", "CLIENT_NAME", "FILE_NAME",
|
||||||
"GENERATION_TIME", "GENERATION_ID", "MESSAGE_ID", "PARENT_ID"
|
"GENERATION_TIME", "GENERATION_ID", "MESSAGE_ID", "PARENT_ID", "WORKFLOW_STATUS"
|
||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -67,6 +66,7 @@ public class SDf10MapStore extends TemplateMapStore<SDf10> {
|
||||||
object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class));
|
object.setGenerationId(resultSet.getObject("GENERATION_ID", Long.class));
|
||||||
object.setMessageId(resultSet.getObject("MESSAGE_ID", String.class));
|
object.setMessageId(resultSet.getObject("MESSAGE_ID", String.class));
|
||||||
object.setParentId(resultSet.getObject("PARENT_ID", String.class));
|
object.setParentId(resultSet.getObject("PARENT_ID", String.class));
|
||||||
|
object.setWorkflowStatus(resultSet.getObject("WORKFLOW_STATUS", String.class));
|
||||||
return object;
|
return object;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
@ -83,7 +83,8 @@ public class SDf10MapStore extends TemplateMapStore<SDf10> {
|
||||||
TimeUtil.toDateFromInstant(object.getGenerationTime()),
|
TimeUtil.toDateFromInstant(object.getGenerationTime()),
|
||||||
object.getGenerationId(),
|
object.getGenerationId(),
|
||||||
object.getMessageId(),
|
object.getMessageId(),
|
||||||
object.getParentId()
|
object.getParentId(),
|
||||||
|
object.getWorkflowStatus()
|
||||||
};
|
};
|
||||||
return args;
|
return args;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
|
|
@ -14,7 +14,7 @@ public class HazelcastLifecycleSupport extends AbstractHazelcastLifecycleSupport
|
||||||
/**
|
/**
|
||||||
* Рабочая версия БД. Требуется вручную сверять с DDL.sql и накручивать эту переменную.
|
* Рабочая версия БД. Требуется вручную сверять с DDL.sql и накручивать эту переменную.
|
||||||
*/
|
*/
|
||||||
public static final String CHECK_DB_VERSION = "3.22";
|
public static final String CHECK_DB_VERSION = "3.27";
|
||||||
|
|
||||||
private final Logger log = LoggerFactory.getLogger(this.getClass());
|
private final Logger log = LoggerFactory.getLogger(this.getClass());
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue