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

http://jira.mfd.msk:8088/browse/CLS-765 fix (property must be unnecessary)

Browse source
This commit is contained in:
akulikov 2024-10-03 20:20:49 +03:00
parent dccfc37439
commit 128b5b681b
5 changed files with 6 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -32,7 +32,7 @@ public class CurrencyExporterService extends AbstractExporterService {
public CurrencyExporterService(SFTPConfig.LimGateway gateway,
KafkaSender kafkaSender,
ImdgProvider imdgProvider,
@Value("${export-lim.include-ck}") String includeCKStrValue) {
@Value("${export-lim-service.include-ck}") String includeCKStrValue) {
super(gateway, kafkaSender, imdgProvider);
includeCK = Boolean.parseBoolean(includeCKStrValue);
}

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

@ -32,7 +32,7 @@ public class MoneyExporterService extends AbstractExporterService {
public MoneyExporterService(SFTPConfig.LimGateway gateway,
KafkaSender kafkaSender,
ImdgProvider imdgProvider,
@Value("${export-lim.include-ck}") String includeCKStrValue) {
@Value("${export-lim-service.include-ck}") String includeCKStrValue) {
super(gateway, kafkaSender, imdgProvider);
includeCK = Boolean.parseBoolean(includeCKStrValue);
}

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

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

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

@ -1,18 +1,8 @@
package ru.spcex.clearing.lim.exporter.services;
import javax.annotation.PostConstruct;
import org.junit.jupiter.api.Test;
import ru.spcex.clearing.lim.exporter.AbstractServiceTest;
import ru.spcex.clearing.lim.exporter.config.KafkaConfig;
import ru.spcex.clearing.lim.exporter.config.settings.ExportLimServiceSettings;
import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
import ru.spcex.clearing.platform.messaging.service.sender.KafkaSenderBuilderImpl;
import ru.spcex.clearing.test.TestUtils;
import javax.annotation.PostConstruct;
import java.time.LocalDateTime;
import static org.junit.jupiter.api.Assertions.*;
class AbstractExporterServiceTest extends AbstractServiceTest {
@PostConstruct
@ -22,7 +12,7 @@ class AbstractExporterServiceTest extends AbstractServiceTest {
@Test
void sendLimExportedNotification() {
AbstractExporterService moneyExporterService = new MoneyExporterService(null, kafkaSender, imdgProvider);
AbstractExporterService moneyExporterService = new MoneyExporterService(null, kafkaSender, imdgProvider, "true");
String fileName = "limits_money_202305241832.lim";
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);
MoneyExporterService moneyExporterService = new MoneyExporterService(null, kafkaSender, imdgProvider);
MoneyExporterService moneyExporterService = new MoneyExporterService(null, kafkaSender, imdgProvider, "true");
Collection<String> limFileRows = moneyExporterService.getLimFileRows();
assertEquals(0, limFileRows.size());