treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

http://jira.mfd.msk:8088/browse/CLS-310

Browse source 
Добавил очередь для отправки ДФ-55.
This commit is contained in:
psemenkov 2023-08-14 16:28:24 +03:00
parent 122e5f9d26
commit 8681cb4db4
2 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/DbfImportKafkaMessenger.java
View file

@ -30,11 +30,12 @@ public class DbfImportKafkaMessenger implements InitializingBean {
@Override
public void afterPropertiesSet() {
messengers.put(ETable.DF_01, groupId -> messageStatement(groupId, SdfTable.SDF_01));
messengers.put(ETable.DF_04, groupId -> messageStatement(groupId, SdfTable.SDF_04));
messengers.put(ETable.DF_06, groupId -> messageStatement(groupId, SdfTable.SDF_06, Consts.STATEMENT_PROCESS_SDF06));
messengers.put(ETable.DF_09, groupId -> messageStatement(groupId, SdfTable.SDF_09));
messengers.put(ETable.DF_16, groupId -> messageStatement(groupId, SdfTable.SDF_16));
messengers.put(ETable.DF_55, groupId -> messageStatement(groupId, SdfTable.SDF_55));
messengers.put(ETable.DF_57, groupId -> messageStatement(groupId, SdfTable.SDF_57));
messengers.put(ETable.DF_04, groupId -> messageStatement(groupId, SdfTable.SDF_04));
}
/**

1
platform-parent/platform-enum/src/main/java/ru/spcex/platform/enumeration/SdfTable.java
View file

@ -16,6 +16,7 @@ public enum SdfTable implements IEnumKey {
SDF_16("SDF_16"),
SDF_20("SDF_20"),
SDF_21("SDF_21"),
SDF_55("SDF_55"),
SDF_57("SDF_57");
SdfTable(String key) {