http://jira.mfd.msk:8088/browse/CLS-189 added logging

clearing-parent/balance-service/src/main/java/ru/spcex/clearing/balance/service/AccountBalanceService.java

@@ -1,5 +1,7 @@
 package ru.spcex.clearing.balance.service;
 
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.stereotype.Component;
 import ru.clearing.classes.statics.data.account.Account;
@@ -28,6 +30,7 @@ import java.util.function.Function;
 
 @Component
 public class AccountBalanceService {
+    private final Logger log = LoggerFactory.getLogger(getClass());
     private final ImdgProvider imdgProvider;
     private final Imdg<AccountBalance> accountBalanceImdg;
     private final Function<AccountBalanceValidation, IValidator> validationFactory;
@@ -122,6 +125,7 @@ public class AccountBalanceService {
         accountBalance.setChangeBalanceAmount(previousChangeBalanceAmount.subtract(firstLegAmount));
         accountBalance.setBalanceAmount(previousBalanceAmount.subtract(firstLegAmount));
         accountBalance.setUpdated(Instant.now());
+        log.trace("updateAccountCategoryIClrn: {}", accountBalance.getId());
         accountBalanceImdg.update(accountBalance);
     }
 
@@ -130,6 +134,7 @@ public class AccountBalanceService {
         BigDecimal previousDebitAmount = accountBalance.getDebitAmount();
         accountBalance.setDebitAmount(previousDebitAmount.add(firstLegAmount.abs()));
         accountBalance.setUpdated(Instant.now());
+        log.trace("updateAccountCategoryITran: {}", accountBalance.getId());
         accountBalanceImdg.update(accountBalance);
     }
 
@@ -142,6 +147,7 @@ public class AccountBalanceService {
         accountBalance.setChangeBalanceAmount(changeBalanceAmount.subtract(firstLegAmount));
         accountBalance.setBalanceAmount(balanceAmount.subtract(firstLegAmount));
         accountBalance.setUpdated(Instant.now());
+        log.trace("updateAccountCategoryVInfo: {}", accountBalance.getId());
         accountBalanceImdg.update(accountBalance);
     }
 
@@ -154,6 +160,7 @@ public class AccountBalanceService {
         accountBalance.setChangeBalanceAmount(previousChangeBalanceAmount.subtract(firstLegAmount));
         accountBalance.setBalanceAmount(previousBalanceAmount.subtract(firstLegAmount));
         accountBalance.setUpdated(Instant.now());
+        log.trace("updateAccountCategoryVAnlt: {}", accountBalance.getId());
         accountBalanceImdg.update(accountBalance);
     }
 
@@ -162,6 +169,7 @@ public class AccountBalanceService {
         BigDecimal debitAmount = accountBalance.getDebitAmount();
         accountBalance.setDebitAmount(plus(debitAmount, firstLegAmount.abs()));
         accountBalance.setUpdated(Instant.now());
+        log.trace("updateAccountCategoryBClrn: {}", accountBalance.getId()");
         accountBalanceImdg.update(accountBalance);
     }
 

clearing-parent/balance-service/src/main/java/ru/spcex/clearing/balance/service/StatementService.java

@@ -70,7 +70,11 @@ public class StatementService extends QueueConsumer implements InitializingBean
     }
 
     private void accountBalanceClearingUpdate(BaseRequest<AccountBalanceClearingRequest> updateAccBalanceReq) {
-        accountBalanceService.updateAccountBalanceByClearing(updateAccBalanceReq.getRequestPayload());
+        AccountBalanceClearingRequest payload = updateAccBalanceReq.getRequestPayload();
+        log.debug("updating account balance for clearing baseRequest.id = {}; accountId = {}, companyId = {}, firstLegAmount = {}", updateAccBalanceReq.getId()
+                payload.getAccountId(), payload.getCompanyId(), payload.getFirstLegAmount()
+        );
+        accountBalanceService.updateAccountBalanceByClearing(payload);
         CommonIdRequest commonIdRequest = new CommonIdRequest();
         commonIdRequest.setId(updateAccBalanceReq.getId());
         kafkaReqProducer.sendRequestToQueue(Consts.CONTINUE_CLEARING, commonIdRequest);

clearing-parent/clearing-service/src/main/resources/logback.xml

@@ -34,4 +34,9 @@
         <appender-ref ref="FILE"/>
         <appender-ref ref="CONSOLE"/>
     </logger>
+
+    <logger name="ru.spcex.clearing.service.Clearing" level="trace" additivity="false">
+        <appender-ref ref="FILE"/>
+        <appender-ref ref="CONSOLE"/>
+    </logger>
 </configuration>