From 6740c4ed231391db64cfeb2fbe122478576597d4 Mon Sep 17 00:00:00 2001 From: ialbert Date: Tue, 8 Aug 2023 16:25:13 +0300 Subject: [PATCH] StatementService SDF types restriction --- .../java/ru/spcex/clearing/service/StatementService.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java index 04cc4249b..b712a77ea 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/StatementService.java @@ -67,6 +67,11 @@ public class StatementService extends QueueConsumer implements InitializingBean callback(StatementRequest.class) .setConsumer(systemRequest -> { StatementRequest payload = systemRequest.getRequestPayload(); + if (payload.getTable() == null + || !Arrays.asList(SdfTable.SDF_01, SdfTable.SDF_57, SdfTable.SDF_08, SdfTable.SDF_13).contains(payload.getTable())) { + log.debug("StatementService: skipping table {}", payload.getTable()); + return; + } if (payload.isContinueSdf()) { processAccountAnswer(systemRequest); } else {