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

clearing-service sdf08 обработка автосоздания счетов. Оказалось что DEPO ужно делать (част 1/2)

Browse source
This commit is contained in:
AKurakin 2023-06-09 17:35:10 +03:00
parent ad09a31171
commit 872b66984d
2 changed files with 7 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -147,7 +147,11 @@ public class StatementService extends QueueConsumer implements InitializingBean
AbstractExecutor service = executorsMap.get(SdfTable.SDF_08);
if (service != null) {
Result res = service.execute(sdfGroup, statementRequest);
finishSendCommand(res, service, statementRequest);
if (res.getAccountRequests().size() != 0) {
kafkaSender.sendRequestToQueue(Consts.ACCOUNT_NEW_SDF08, createAccountsRequest(statementRequest.getGroupId(), res.getAccountRequests()));
} else if (service.isNeedToSendCommand()) {
service.sendCommand(kafkaSender, res);
}
} else {
log.warn("Executor for SDF_08 not set");
}
@ -177,12 +181,7 @@ public class StatementService extends QueueConsumer implements InitializingBean
.collect(Collectors.toList());
}
AbstractExecutor service = executorsMap.get(SdfTable.SDF_01);
Result res = service.execute(sdfGroup, statementRequest);
finishSendCommand(res, service, statementRequest);
}
void finishSendCommand(Result res, AbstractExecutor service, StatementRequest statementRequest) {
if (res.getAccountRequests().size() != 0) {
Result res = service.execute(sdfGroup, statementRequest); if (res.getAccountRequests().size() != 0) {
kafkaSender.sendRequestToQueue(Consts.ACCOUNT_NEW_SDF01, createAccountsRequest(statementRequest.getGroupId(), res.getAccountRequests()));
} else if (service.isNeedToSendCommand()) {
service.sendCommand(kafkaSender, res);

1
platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/domain/Consts.java
View file

@ -86,6 +86,7 @@ public interface Consts {
String CREATE_REPORT_FOR_REGISTRY = "create-report-for-registry";
String ACCOUNT_NEW_SDF01 = "account-new-sdf01";
String ACCOUNT_NEW_SDF08 = "account-new-sdf08";
String DESTINATION_RELATION_NEW = "relation-new";
String DESTINATION_RELATION_UPDATE = "relation-update";