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

lim-exporter http://jira.mfd.msk:8088/browse/CLS-913

Browse source
This commit is contained in:
AKurakin 2025-10-28 12:25:03 +03:00
parent 20cd02a678
commit a3c08bc455
5 changed files with 17 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/CurrencyExporterService.java
View file

@ -28,13 +28,18 @@ public class CurrencyExporterService extends AbstractExporterService {
private final Logger log = LoggerFactory.getLogger(getClass()); private final Logger log = LoggerFactory.getLogger(getClass());
private boolean includeCK; private boolean includeCK;
private String moneyLimitTag;
public CurrencyExporterService(SFTPConfig.LimGateway gateway, public CurrencyExporterService(SFTPConfig.LimGateway gateway,
KafkaSender kafkaSender, KafkaSender kafkaSender,
ImdgProvider imdgProvider, ImdgProvider imdgProvider,
@Value("${export-lim-service.include-ck:false}") String includeCKStrValue) { @Value("${export-lim-service.include-ck:false}") String includeCKStrValue,
@Value("${export-lim-service.money-limit-tag:SPVB}") String moneyLimitTag
) {
super(gateway, kafkaSender, imdgProvider); super(gateway, kafkaSender, imdgProvider);
includeCK = Boolean.parseBoolean(includeCKStrValue); includeCK = Boolean.parseBoolean(includeCKStrValue);
this.moneyLimitTag = moneyLimitTag.trim();
log.debug("Configured moneyLimitTag={}", this.moneyLimitTag);
} }
@Override @Override
@ -141,7 +146,7 @@ public class CurrencyExporterService extends AbstractExporterService {
row.append("MONEY: FIRM_ID = "); row.append("MONEY: FIRM_ID = ");
row.append(registryA.getTradingCode()); row.append(registryA.getTradingCode());
row.append("; TAG = SPVB"); row.append("; TAG = ").append(moneyLimitTag); // default SPVB
row.append("; CURR_CODE = "); row.append("; CURR_CODE = ");
row.append(registryA.getSecuritySymbol()); row.append(registryA.getSecuritySymbol());

8
clearing-parent/lim-exporter/src/main/java/ru/spcex/clearing/lim/exporter/services/MoneyExporterService.java
View file

@ -28,13 +28,17 @@ public class MoneyExporterService extends AbstractExporterService {
private final Logger log = LoggerFactory.getLogger(getClass()); private final Logger log = LoggerFactory.getLogger(getClass());
private boolean includeCK; private boolean includeCK;
private String moneyLimitTag;
public MoneyExporterService(SFTPConfig.LimGateway gateway, public MoneyExporterService(SFTPConfig.LimGateway gateway,
KafkaSender kafkaSender, KafkaSender kafkaSender,
ImdgProvider imdgProvider, ImdgProvider imdgProvider,
@Value("${export-lim-service.include-ck:false}") String includeCKStrValue) { @Value("${export-lim-service.include-ck:false}") String includeCKStrValue,
@Value("${export-lim-service.money-limit-tag:SPVB}") String moneyLimitTag) {
super(gateway, kafkaSender, imdgProvider); super(gateway, kafkaSender, imdgProvider);
includeCK = Boolean.parseBoolean(includeCKStrValue); includeCK = Boolean.parseBoolean(includeCKStrValue);
this.moneyLimitTag = moneyLimitTag.trim();
log.debug("Configured moneyLimitTag={}", this.moneyLimitTag);
} }
@Override @Override
@ -144,7 +148,7 @@ public class MoneyExporterService extends AbstractExporterService {
row.append("MONEY: FIRM_ID = "); row.append("MONEY: FIRM_ID = ");
row.append(registryA.getTradingCode()); row.append(registryA.getTradingCode());
row.append("; TAG = SPVB"); row.append("; TAG = ").append(moneyLimitTag); // default SPVB
row.append("; CURR_CODE = "); row.append("; CURR_CODE = ");
row.append(registryA.getSecuritySymbol()); row.append(registryA.getSecuritySymbol());

3
clearing-parent/lim-exporter/src/main/resources/application.properties
View file

@ -28,4 +28,5 @@ export-lim-service.kafka-producer.batch-size=16384
export-lim-service.kafka-producer.linger-ms=1 export-lim-service.kafka-producer.linger-ms=1
export-lim-service.kafka-producer.buffer-memory=33554432 export-lim-service.kafka-producer.buffer-memory=33554432
export-lim-service.include-ck=true export-lim-service.include-ck=true
export-lim-service.money-limit-tag=SPVB

2
clearing-parent/lim-exporter/src/test/java/ru/spcex/clearing/lim/exporter/services/AbstractExporterServiceTest.java
View file

@ -12,7 +12,7 @@ class AbstractExporterServiceTest extends AbstractServiceTest {
@Test @Test
void sendLimExportedNotification() { void sendLimExportedNotification() {
AbstractExporterService moneyExporterService = new MoneyExporterService(null, kafkaSender, imdgProvider, "true"); AbstractExporterService moneyExporterService = new MoneyExporterService(null, kafkaSender, imdgProvider, "true", "SPVB");
String fileName = "limits_money_202305241832.lim"; String fileName = "limits_money_202305241832.lim";
moneyExporterService.sendLimExportedNotification(fileName); moneyExporterService.sendLimExportedNotification(fileName);

2
clearing-parent/lim-exporter/src/test/java/ru/spcex/clearing/lim/exporter/services/MoneyExporterServiceTest.java
View file

@ -63,7 +63,7 @@ class MoneyExporterServiceTest extends AbstractServiceTest {
registryImdg.insert(registryT_2); registryImdg.insert(registryT_2);
MoneyExporterService moneyExporterService = new MoneyExporterService(null, kafkaSender, imdgProvider, "true"); MoneyExporterService moneyExporterService = new MoneyExporterService(null, kafkaSender, imdgProvider, "true", "SPVB");
Collection<String> limFileRows = moneyExporterService.getLimFileRows(); Collection<String> limFileRows = moneyExporterService.getLimFileRows();
assertEquals(0, limFileRows.size()); assertEquals(0, limFileRows.size());