From 34faab92202e86a349218fe27d6678f5f599bb38 Mon Sep 17 00:00:00 2001 From: ialbert Date: Mon, 19 Jun 2023 19:07:21 +0300 Subject: [PATCH] SDF06 executor bugfix --- .../ru/spcex/clearing/service/executors/Sdf06Executor.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf06Executor.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf06Executor.java index 46dc9254b..ea170e1a3 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf06Executor.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf06Executor.java @@ -117,8 +117,10 @@ public class Sdf06Executor { log.debug("Statement created: {}", stmt.getId()); requests.add(requestFromStatement(stmt, company.getTradingCode(), tcr.getCode())); } - sdf06GroupId = groupId; - kafkaSender.sendRequestToQueue(Consts.ASSET_OPERATION, requests); + if (requests.size() > 0) { + sdf06GroupId = groupId; + kafkaSender.sendRequestToQueue(Consts.ASSET_OPERATION, requests); + } } public void processGatewayResponse(BaseRequest req) {