parent
dab63ad8be
commit
0db6f75823
1 changed files with 2 additions and 4 deletions
|
|
@ -59,10 +59,8 @@ public class MoneyPaymentInstructionRegisterService extends QueueConsumer implem
|
|||
Collection<PaymentInstruction> paymentInstructionBySessionId =
|
||||
paymentInstructionMap.getCollectionObjectsByFieldValues(fieldValuesSessionId);
|
||||
for (PaymentInstruction paymentInstruction : paymentInstructionBySessionId) {
|
||||
MoneyPaymentInstructionRegister moneyPaymentInstructionRegister = moneyPaymentInstructionRegisterMap.getSingleObjectByFieldValues(Map.of(
|
||||
"companyId", paymentInstruction.getSenderId(),
|
||||
"sessionId", paymentInstruction.getSessionId())
|
||||
);
|
||||
Map<String, ? extends Comparable<?>> fieldValuesCompanyIdSessionId = getFieldValuesOrThrowException(Map.of("companyId", paymentInstruction.getSenderId(), "sessionId", paymentInstruction.getSessionId()));
|
||||
MoneyPaymentInstructionRegister moneyPaymentInstructionRegister = moneyPaymentInstructionRegisterMap.getSingleObjectByFieldValues(fieldValuesCompanyIdSessionId);
|
||||
if (moneyPaymentInstructionRegister == null) {
|
||||
insertMoneyPaymentInstructionRegister(paymentInstruction);
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue