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

delete sdf12 from importer

Browse source
This commit is contained in:
etreschenkov 2023-05-24 12:43:46 +03:00
parent 73c8cce9c2
commit 28d7176a5c
5 changed files with 5 additions and 37 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/config/DBFImporterConfig.java
View file

@ -59,7 +59,6 @@ public class DBFImporterConfig {
map.put(ETable.DF_01, new SDf01Table());
map.put(ETable.DF_04, new SDf04Table());
map.put(ETable.DF_09, new SDf09Table());
map.put(ETable.DF_12, new SDf12Table());
map.put(ETable.DF_16, new SDf16Table());
map.put(ETable.DF_57, new SDf57Table());
return map;

2
clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/data/enums/ETable.java
View file

@ -4,7 +4,7 @@ public enum ETable {
DF_01("DF-01"),
DF_04("DF-04"),
DF_09("DF-09"),
DF_12("DF-12"),
// DF_12("DF-12"),
DF_16("DF-16"),
DF_57("DF-57");

32
clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/data/tables/SDf12Table.java
View file

@ -1,32 +0,0 @@
package ru.spcex.clearing.dbf.importer.logic.data.tables;
import ru.clearing.classes.statics.data.sdf.SDf12;
import ru.spcex.clearing.dbf.importer.logic.data.enums.ETable;
import ru.spcex.clearing.imdg.IMDGDistributedNames;
import java.math.BigDecimal;
import java.time.Instant;
public class SDf12Table extends AbstractTable<SDf12> {
private static final String PREFIX = ETable.DF_12.name();
private static final Class<SDf12> CLAZZ = SDf12.class;
private static final String NAME_OF_HZ_MAP = IMDGDistributedNames.Map_SDf12;
public SDf12Table() {
super(PREFIX, CLAZZ, NAME_OF_HZ_MAP);
}
@Override
public SDf12 getEntity(Object[] entity) {
SDf12 result = new SDf12();
// result.setAccount((String) entity[0]);
// result.setDeal((String) entity[1]);
BigDecimal status = (BigDecimal) entity[2];
// result.setStatus(status != null ? status.longValue() : null);
// result.setFileName(filename);
result.setGenerationTime(Instant.now());
result.setGenerationId(fileId);
return result;
}
}

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

@ -29,6 +29,7 @@ public class DbfImportKafkaMessenger implements InitializingBean {
messengers.put(ETable.DF_01, groupId -> messageBalance(groupId, SdfTable.SDF_01));
messengers.put(ETable.DF_09, groupId -> messageBalance(groupId, SdfTable.SDF_09));
messengers.put(ETable.DF_16, groupId -> messageBalance(groupId, SdfTable.SDF_16));
messengers.put(ETable.DF_57, groupId -> messageBalance(groupId, SdfTable.SDF_57));
messengers.put(ETable.DF_04, this::messageDf04);
}

6
clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/services/LauncherCommandReceiver.java
View file

@ -23,6 +23,9 @@ public class LauncherCommandReceiver extends QueueConsumer implements Initializi
this.importer = importer;
}
/**
* В реальности не используется
*/
@Override
public void afterPropertiesSet() {
callback(LauncherCommandRequest.class)
@ -31,9 +34,6 @@ public class LauncherCommandReceiver extends QueueConsumer implements Initializi
callback(LauncherCommandRequest.class)
.setConsumer(action -> importer.run(ETable.DF_01))
.forDestination(Task.accrualOfBalance.topic(), callbacks::put); // GBAL
callback(LauncherCommandRequest.class)
.setConsumer(action -> importer.run(ETable.DF_12))
.forDestination(Task.accountBlock.topic(), callbacks::put); // ABLK
callback(LauncherCommandRequest.class)
.setConsumer(action -> importer.run(ETable.DF_09))
.forDestination(Task.getBalance.topic(), callbacks::put); // GBLD