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

balance-service put sdf02 request to kafka

Browse source
This commit is contained in:
ialbert 2022-09-30 13:42:39 +03:00
parent 0b2e5a13fb
commit 3014515e00
3 changed files with 9 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/AccountService.java
View file

@ -55,7 +55,7 @@ public class AccountService extends QueueConsumer implements InitializingBean {
AccountSdf01ToStatementRequestPart responsePart = responsePart(accountReq.getSdf01Id()); AccountSdf01ToStatementRequestPart responsePart = responsePart(accountReq.getSdf01Id());
accountToStatement.add(responsePart); accountToStatement.add(responsePart);
} }
sendStatementRequestBack(accountToStatement); sendStatementRequestBack(req.getGroupingSdf01Id(), accountToStatement);
log.debug("successfully processed, grouping id={}, processed number={}", req.getGroupingSdf01Id(), accountToStatement.size()); log.debug("successfully processed, grouping id={}, processed number={}", req.getGroupingSdf01Id(), accountToStatement.size());
} }
@ -67,8 +67,9 @@ public class AccountService extends QueueConsumer implements InitializingBean {
return responsePart; return responsePart;
} }
private void sendStatementRequestBack(List<AccountSdf01ToStatementRequestPart> results) { private void sendStatementRequestBack(Long groupingSdf01Id, List<AccountSdf01ToStatementRequestPart> results) {
StatementRequest request = new StatementRequest(); StatementRequest request = new StatementRequest();
request.setSdf01GroupId(groupingSdf01Id);
request.setAccountCreationResults(results); request.setAccountCreationResults(results);
kafkaSender.sendRequestToQueue(Consts.STATEMENT_PROCESS, request); kafkaSender.sendRequestToQueue(Consts.STATEMENT_PROCESS, request);
} }

5
clearing-parent/balance-service/src/main/java/ru/spcex/clearing/balance/service/StatementService.java
View file

@ -19,6 +19,7 @@ import ru.spcex.clearing.platform.messaging.domain.BaseRequest;
import ru.spcex.clearing.platform.messaging.domain.Consts; import ru.spcex.clearing.platform.messaging.domain.Consts;
import ru.spcex.clearing.platform.messaging.domain.cud.account.sdf01.AccountSdf01Request; import ru.spcex.clearing.platform.messaging.domain.cud.account.sdf01.AccountSdf01Request;
import ru.spcex.clearing.platform.messaging.domain.cud.account.sdf01.AccountSdf01RequestPart; import ru.spcex.clearing.platform.messaging.domain.cud.account.sdf01.AccountSdf01RequestPart;
import ru.spcex.clearing.platform.messaging.domain.cud.balance.ExportToFileRequest;
import ru.spcex.clearing.platform.messaging.domain.cud.balance.StatementRequest; import ru.spcex.clearing.platform.messaging.domain.cud.balance.StatementRequest;
import ru.spcex.clearing.platform.messaging.service.QueueConsumer; import ru.spcex.clearing.platform.messaging.service.QueueConsumer;
import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender; import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
@ -133,6 +134,10 @@ public class StatementService extends QueueConsumer implements InitializingBean
if (accountRequests.size() > 0) { if (accountRequests.size() > 0) {
kafkaReqProducer.sendRequestToQueue(Consts.ACCOUNT_NEW, createAccountsRequest(sdf01.getGenerationId(), accountRequests)); kafkaReqProducer.sendRequestToQueue(Consts.ACCOUNT_NEW, createAccountsRequest(sdf01.getGenerationId(), accountRequests));
} else {
ExportToFileRequest exportRequest = new ExportToFileRequest();
exportRequest.setSdfGroupId(statementRequest.getSdf01GroupId());
exportRequest.setNameOfTable("DF-02");
} }
} }
} }

2
clearing-parent/balance-service/src/main/resources/application.properties
View file

@ -4,7 +4,7 @@ balance-service.hazelcast.login=dev
balance-service.hazelcast.password=dev-pass balance-service.hazelcast.password=dev-pass
balance-service.kafka-consumer.bootstrap-servers=localhost:9092 balance-service.kafka-consumer.bootstrap-servers=localhost:9092
balance-service.kafka-consumer.group-id=dev-group balance-service.kafka-consumer.group-id=dev-group-balance-service
balance-service.kafka-consumer.enable-auto-commit=false balance-service.kafka-consumer.enable-auto-commit=false
balance-service.kafka-consumer.session-timeout-ms=30000 balance-service.kafka-consumer.session-timeout-ms=30000
balance-service.kafka-consumer.auto-offset-reset=latest balance-service.kafka-consumer.auto-offset-reset=latest