diff --git a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/ClearingAccountService.java b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/ClearingAccountService.java index e92187e32..f95716e4a 100644 --- a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/ClearingAccountService.java +++ b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/ClearingAccountService.java @@ -793,7 +793,7 @@ public class ClearingAccountService extends QueueConsumer implements Initializin } if (returnTrigger) { log.debug("Remove from waiting list accountId={} (list groupId={})", accountId, inWaitingLst.getGroupId()); - waitingList.remove(inWaitingLst); + waitingList.remove(accountId); } if (returnTrigger) return inWaitingLst; diff --git a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/v2/listeners/ClientCodeMessageListener.java b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/v2/listeners/ClientCodeMessageListener.java index ee8a81f81..a2d20ec51 100644 --- a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/v2/listeners/ClientCodeMessageListener.java +++ b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/service/v2/listeners/ClientCodeMessageListener.java @@ -132,7 +132,7 @@ public class ClientCodeMessageListener extends QueueConsumer implements Initiali clientCodeNewRequest.setCompanyId(company.getId()); clientCodeNewRequest.setCode(tkrAccount.getClientCode()); clientCodeNewRequest.setDepoAccountId(depoAccountId); - Account moneyAccount = accountByCurrency.get(CurrencyCode.RUB); + Account moneyAccount = accountByCurrency.get(CurrencyCode.RUB.getKey()); clientCodeNewRequest.setMoneyAccountId(moneyAccount.getId()); List foreignCurrencyList = accountByCurrency.entrySet() diff --git a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/config/MetaConfiguration.java b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/config/MetaConfiguration.java index 515707844..639edd9fb 100644 --- a/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/config/MetaConfiguration.java +++ b/clearing-parent/backend-api/src/main/java/ru/spcex/clearing/backendapi/config/MetaConfiguration.java @@ -17,7 +17,7 @@ import java.nio.file.Files; @Configuration public class MetaConfiguration { - @Value("file:${spring.config.location}/meta.json") + @Value("file:${spring.config.location}/meta/meta.json") private Resource meta; @Bean("metaJson") diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/payment/PaymentInstructionOutboundService.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/payment/PaymentInstructionOutboundService.java index fc181c258..80b59e008 100644 --- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/payment/PaymentInstructionOutboundService.java +++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/payment/PaymentInstructionOutboundService.java @@ -188,9 +188,14 @@ public class PaymentInstructionOutboundService { sDf54.setId(idGenerator.nextId()); sDf54.setGenerationId(pmt.getId()); if (time.isTradingTime()) { - Supplier builder = () -> GatewayRequestCreator.from(pmt, - assets.get().a__b().getTradingCode(), - tcr.getCode()); + Supplier builder = () -> { + if (tcr != null) { + return GatewayRequestCreator.from(pmt, + assets.get().a__b().getTradingCode(), + tcr.getCode()); + } + return null; + }; Optional gatewayOk = gateway.gatewayRequestAndWait(builder); if (gatewayOk.isEmpty() || gatewayOk.get().equals(Boolean.FALSE)) { String gtwErrMsg = msgs.resolve(mapError(gatewayOk)); diff --git a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/DbfImportKafkaMessenger.java b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/DbfImportKafkaMessenger.java index 597e99404..89f21e00f 100644 --- a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/DbfImportKafkaMessenger.java +++ b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/logic/stages/DbfImportKafkaMessenger.java @@ -60,7 +60,7 @@ public class DbfImportKafkaMessenger implements InitializingBean { } public void notifyUserAboutErrorParsing(Throwable error, ResultContainer resultContainer) { - if (resultContainer == null || resultContainer.getDbfFile() == null || resultContainer.getDbfFile() == null) + if (resultContainer == null || resultContainer.getDbfFile() == null || resultContainer.getDbfTable() == null) return; ETable currTable = resultContainer.getDbfTable(); String fileName = resultContainer.getDbfFile().getName(); diff --git a/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java b/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java index 054038f4c..363d0cda6 100644 --- a/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java +++ b/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java @@ -213,8 +213,7 @@ public class TradeImporterService { private boolean isValidTrades(STrades trades) { return trades.getTradeDate() != null && trades.getTradeNum() != null - && StringUtils.hasText(trades.getOperation()) - && trades.getTradeNum() != null; + && StringUtils.hasText(trades.getOperation()); } public STrades readSTrades(ResultSet resultSet) throws SQLException { diff --git a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java index bfe4c6cb4..ca4322b92 100644 --- a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java +++ b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumer.java @@ -2,6 +2,7 @@ package ru.spcex.clearing.platform.messaging.service; import com.fasterxml.jackson.databind.JavaType; import com.fasterxml.jackson.databind.ObjectMapper; +import java.util.concurrent.ExecutionException; import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; @@ -196,7 +197,7 @@ public class QueueConsumer implements AutoCloseable { } send = producer.send(respRec); send.get(); - } catch (Exception e) { + } catch (InterruptedException | ExecutionException e) { log.error(ExceptionUtils.getStackTrace(e)); } }); diff --git a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumerV2.java b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumerV2.java index 38d084745..ef9a50f6c 100644 --- a/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumerV2.java +++ b/platform-parent/platform-messaging/src/main/java/ru/spcex/clearing/platform/messaging/service/QueueConsumerV2.java @@ -6,6 +6,7 @@ import java.util.HashMap; import java.util.Map; import java.util.Optional; import java.util.concurrent.CompletableFuture; +import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; @@ -215,7 +216,7 @@ public class QueueConsumerV2 implements AutoCloseable { } send = producer.send(respRec); send.get(); - } catch (Exception e) { + } catch (InterruptedException | ExecutionException e) { log.error(ExceptionUtils.getStackTrace(e)); } });