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

http://jira.mfd.msk:8088/browse/CLS-189 fix SDF 03/11 отправку сообщений на создание (поправил опечатки)

Browse source
This commit is contained in:
AKurakin 2023-02-10 11:53:33 +03:00
parent fde8174e86
commit daa2e880ff
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/SdfCreatorBySTLDPayment.java
View file

@ -65,19 +65,19 @@ public class SdfCreatorBySTLDPayment {
/*Map<GroupWrapper, List<PaymentInstruction>> byOrder = */ /*Map<GroupWrapper, List<PaymentInstruction>> byOrder = */
List<Map.Entry<GroupWrapper, Collection<List<PaymentInstruction>>>> allEntries = group(paymentInstructionFound); List<Map.Entry<GroupWrapper, Collection<List<PaymentInstruction>>>> allEntries = group(paymentInstructionFound);
Set<String> queueToSend = new HashSet<>();
allEntries.forEach(entry -> { allEntries.forEach(entry -> {
log.info("Group category {}, index {}", entry.getKey().category, entry.getKey().getSortIndex()); log.info("Group category {}, index {}", entry.getKey().category, entry.getKey().getSortIndex());
GroupWrapper group = entry.getKey(); GroupWrapper group = entry.getKey();
Collection<List<PaymentInstruction>> bySenderGroups = entry.getValue(); Collection<List<PaymentInstruction>> bySenderGroups = entry.getValue();
Set<String> queueToSend = new HashSet<>();
for (List<PaymentInstruction> bySenderGroup : bySenderGroups) { for (List<PaymentInstruction> bySenderGroup : bySenderGroups) {
Long senderIdSpecificToGroup = bySenderGroup.iterator().next().getSenderId(); Long senderIdSpecificToGroup = bySenderGroup.iterator().next().getSenderId();
log.info("Group senderId {}", senderIdSpecificToGroup); log.info("Group senderId {}", senderIdSpecificToGroup);
queueToSend.add(saveSdfBeforeSendToKafka(senderIdSpecificToGroup, group.category, bySenderGroup, generationId)); queueToSend.add(saveSdfBeforeSendToKafka(senderIdSpecificToGroup, group.category, bySenderGroup, generationId));
} }
log.info("Send command target queue: {}", queueToSend);
sendToKafkaSDFRequests(queueToSend, generationId);
}); });
log.info("Send command target queue: {}", queueToSend);
sendToKafkaSDFRequests(queueToSend, generationId);
allEntries.forEach(entry -> { allEntries.forEach(entry -> {
//category group //category group
GroupWrapper group = entry.getKey(); GroupWrapper group = entry.getKey();
@ -158,8 +158,8 @@ public class SdfCreatorBySTLDPayment {
} }
SdfClearingRequest kafkaMessage = new SdfClearingRequest(); SdfClearingRequest kafkaMessage = new SdfClearingRequest();
kafkaMessage.setGroupId(generationId); kafkaMessage.setGroupId(generationId);
Long requestId = kafkaSender.sendRequestToQueue(Consts.SDF03_PROCESS, kafkaMessage); Long requestId = kafkaSender.sendRequestToQueue(kQueue, kafkaMessage);
log.debug("Send to kafka command, queue={}, requestId={}", kQueue, requestId); log.debug("Send to kafka command, queue={}, requestId={}, generationId={}", kQueue, requestId, generationId);
} }
} }