diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf57Executor.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf57Executor.java index 4986c50fd..6885b4ae4 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf57Executor.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/executors/Sdf57Executor.java @@ -355,11 +355,16 @@ public class Sdf57Executor extends AbstractExecutor { statementImdg.update(stmt); log.debug("stmt.id={} status -> {}", stmt.getId(), OperationStatus.Executed.getKey()); if (!dm_tWasCreated && timeService.isTradingTime() && InOutDirection.in.equalsByKey(stmt.getInOutDirection())) { - log.trace("sending gateway request for stmt.id={}", stmt.getId()); - kafka.sendRequestToQueue(Consts.ASSET_OPERATION, - gatewayRequest(stmt, - company.getTradingCode(), - asts.a__t().getTradingClearingRegistry())); + if (TextUtil.isEmpty(asts.a__t().getTradingClearingRegistry())) { + log.trace("stmt.id={} {}.id={} TCR is empty, skipping gateway request", + stmt.getId(), asts.a__t().getRegistryCode(), asts.a__t().getId()); + } else { + log.trace("sending gateway request for stmt.id={}", stmt.getId()); + kafka.sendRequestToQueue(Consts.ASSET_OPERATION, + gatewayRequest(stmt, + company.getTradingCode(), + asts.a__t().getTradingClearingRegistry())); + } } return Optional.of(asts); } else {