treshenkov/clearing
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

reports-service http://jira.mfd.msk:8088/browse/CLS-497 улучшил логирование

Browse source
This commit is contained in:
AKurakin 2023-09-22 15:19:30 +03:00
parent bef57e096b
commit 57bbce07da
10 changed files with 11 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSCommissionTradesReportBuilder.java
View file

@ -86,7 +86,7 @@ public class KSCommissionTradesReportBuilder extends CSVReportBuilder<EmptyParam
pb.or(pb.equals("sessionType", SessionType.XDEP.getKey()), pb.equals("sessionType", SessionType.FINL.getKey())) pb.or(pb.equals("sessionType", SessionType.XDEP.getKey()), pb.equals("sessionType", SessionType.FINL.getKey()))
); );
Collection<Registry> registries = registryImdg.getCollectionObjectsByPredicate(finalPredicate); Collection<Registry> registries = registryImdg.getCollectionObjectsByPredicate(finalPredicate);
log.trace("Found {} Registry by query: {}", registries.size(), finalPredicate); log.debug("Found {} Registry by query: {}", registries.size(), finalPredicate);
rows = new ArrayList<>(registries.size()); rows = new ArrayList<>(registries.size());
for (Registry registry : registries) { for (Registry registry : registries) {
if (registry.getTradingDate() == null) { if (registry.getTradingDate() == null) {

2
clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepCashNettoReportBuilder.java
View file

@ -80,7 +80,7 @@ public class KSRepCashNettoReportBuilder extends CSVReportBuilder<SessionIdParam
pb.notNull("account") pb.notNull("account")
); );
Collection<Registry> registries = registryImdg.getCollectionObjectsByPredicate(finalPredicate); Collection<Registry> registries = registryImdg.getCollectionObjectsByPredicate(finalPredicate);
log.trace("Found {} Registry by query: {}", registries.size(), finalPredicate); log.debug("Found {} Registry by query: {}", registries.size(), finalPredicate);
Map<PairRegistryId, List<Registry>> registryMap = registries.stream().collect(Collectors.groupingBy(PairRegistryId::new)); Map<PairRegistryId, List<Registry>> registryMap = registries.stream().collect(Collectors.groupingBy(PairRegistryId::new));
rows = new ArrayList<>(registryMap.size()); rows = new ArrayList<>(registryMap.size());

2
clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepCashRegisterSumsReportBuilder.java
View file

@ -80,7 +80,7 @@ public class KSRepCashRegisterSumsReportBuilder extends CSVReportBuilder<EmptyPa
pb.equals("operationStatus", OperationStatus.Executed.getKey()) pb.equals("operationStatus", OperationStatus.Executed.getKey())
); );
Collection<Statement> statements = statementImdg.getCollectionObjectsByPredicate(finalPredicate); Collection<Statement> statements = statementImdg.getCollectionObjectsByPredicate(finalPredicate);
log.trace("Found {} Statements by query: {}", statements.size(), finalPredicate); log.debug("Found {} Statements by query: {}", statements.size(), finalPredicate);
rows = new ArrayList<>(statements.size()); rows = new ArrayList<>(statements.size());
for (Statement statement : statements) { for (Statement statement : statements) {
if (statement.getAmount() == null) { if (statement.getAmount() == null) {

2
clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepCashRegistersReportBuilder.java
View file

@ -82,7 +82,7 @@ public class KSRepCashRegistersReportBuilder extends CSVReportBuilder<EmptyParam
) )
); );
Collection<Registry> registries = registryImdg.getCollectionObjectsByPredicate(finalPredicate); Collection<Registry> registries = registryImdg.getCollectionObjectsByPredicate(finalPredicate);
log.trace("Found {} Registry by query: {}", registries.size(), finalPredicate); log.debug("Found {} Registry by query: {}", registries.size(), finalPredicate);
rows = new ArrayList<>(registries.size()); rows = new ArrayList<>(registries.size());
for (Registry registry : registries) { for (Registry registry : registries) {
try { try {

2
clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepDepoNettoReportBuilder.java
View file

@ -77,7 +77,7 @@ public class KSRepDepoNettoReportBuilder extends CSVReportBuilder<SessionIdParam
pb.notNull("account") pb.notNull("account")
); );
Collection<Registry> registries = registryImdg.getCollectionObjectsByPredicate(finalPredicate); Collection<Registry> registries = registryImdg.getCollectionObjectsByPredicate(finalPredicate);
log.trace("Found {} Registry by query: {}", registries.size(), finalPredicate); log.debug("Found {} Registry by query: {}", registries.size(), finalPredicate);
Map<PairRegistryId, List<Registry>> registryMap = registries.stream().collect(Collectors.groupingBy(PairRegistryId::new)); Map<PairRegistryId, List<Registry>> registryMap = registries.stream().collect(Collectors.groupingBy(PairRegistryId::new));
rows = new ArrayList<>(registries.size()); rows = new ArrayList<>(registries.size());

2
clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepDepoRegisterQuantitiesReportBuilder.java
View file

@ -87,7 +87,7 @@ public class KSRepDepoRegisterQuantitiesReportBuilder extends CSVReportBuilder<E
pb.notNull("amount") pb.notNull("amount")
); );
Collection<Statement> statements = statementImdg.getCollectionObjectsByPredicate(finalPredicate); Collection<Statement> statements = statementImdg.getCollectionObjectsByPredicate(finalPredicate);
log.trace("Found {} Statement by query: {}", statements.size(), finalPredicate); log.debug("Found {} Statement by query: {}", statements.size(), finalPredicate);
rows = new ArrayList<>(statements.size()); rows = new ArrayList<>(statements.size());
for (Statement statement : statements) { for (Statement statement : statements) {

2
clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepDepoRegistersReportBuilder.java
View file

@ -78,7 +78,7 @@ public class KSRepDepoRegistersReportBuilder extends CSVReportBuilder<EmptyParam
pb.notNull("tradingClearingRegistry") pb.notNull("tradingClearingRegistry")
); );
Collection<Registry> registries = registryImdg.getCollectionObjectsByPredicate(finalPredicate); Collection<Registry> registries = registryImdg.getCollectionObjectsByPredicate(finalPredicate);
log.trace("Found {} Registry by query: {}", registries.size(), finalPredicate); log.debug("Found {} Registry by query: {}", registries.size(), finalPredicate);
rows = new ArrayList<>(registries.size()); rows = new ArrayList<>(registries.size());
for (Registry registry : registries) { for (Registry registry : registries) {

2
clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepFirmDetailsReportBuilder.java
View file

@ -59,7 +59,7 @@ public class KSRepFirmDetailsReportBuilder extends CSVReportBuilder<EmptyParams,
@Override @Override
protected void collect(EmptyParams params) { protected void collect(EmptyParams params) {
Collection<Company> companies = companyImdg.getCollectionObjectsByFieldValues(Map.of("workflowStatus", WorkflowStatus.Active.getKey())); Collection<Company> companies = companyImdg.getCollectionObjectsByFieldValues(Map.of("workflowStatus", WorkflowStatus.Active.getKey()));
log.trace("Found {} Company", companies.size()); log.debug("Found {} Company", companies.size());
rows = new ArrayList<>(companies.size()); rows = new ArrayList<>(companies.size());
for (Company company : companies) { for (Company company : companies) {

2
clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepTradesReportBuilder.java
View file

@ -83,10 +83,12 @@ public class KSRepTradesReportBuilder extends CSVReportBuilder<EmptyParams, KSRe
Collection<ExecutionDeposit> executionDeposits = executionDepositImdg.getCollectionObjectsByPredicate( Collection<ExecutionDeposit> executionDeposits = executionDepositImdg.getCollectionObjectsByPredicate(
pbExecutionDeposit.equals("tradingDate", nowDate) pbExecutionDeposit.equals("tradingDate", nowDate)
); );
log.debug("Found {} ExecutionDeposit by tradingDate={}", executionDeposits.size(), nowDate);
ImdgPredicateBuilder pbExecutionFond = executionFondImdg.predicateBuilder(); ImdgPredicateBuilder pbExecutionFond = executionFondImdg.predicateBuilder();
Collection<ExecutionFond> executionFonds = executionFondImdg.getCollectionObjectsByPredicate( Collection<ExecutionFond> executionFonds = executionFondImdg.getCollectionObjectsByPredicate(
pbExecutionFond.equals("tradingDate", nowDate) pbExecutionFond.equals("tradingDate", nowDate)
); );
log.debug("Found {} ExecutionFond by tradingDate={}", executionFonds.size(), nowDate);
List<ExecutionCommon> executions = new ArrayList<>(); List<ExecutionCommon> executions = new ArrayList<>();
executions.addAll(executionDeposits); executions.addAll(executionDeposits);
executions.addAll(executionFonds); executions.addAll(executionFonds);

2
clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSSessionListReportBuilder.java
View file

@ -57,7 +57,7 @@ public class KSSessionListReportBuilder extends CSVReportBuilder<EmptyParams, KS
protected void collect(EmptyParams params) { protected void collect(EmptyParams params) {
Map<String, LocalDate> query = Map.of("clearingDate", LocalDate.now()); Map<String, LocalDate> query = Map.of("clearingDate", LocalDate.now());
Collection<Session> sessions = sessionImdg.getCollectionObjectsByFieldValues(query); Collection<Session> sessions = sessionImdg.getCollectionObjectsByFieldValues(query);
log.trace("Found {} Session by query: {}", sessions.size(), query); log.debug("Found {} Session by query: {}", sessions.size(), query);
rows = new ArrayList<>(sessions.size()); rows = new ArrayList<>(sessions.size());
for (Session session : sessions) { for (Session session : sessions) {
try { try {