From 117e94ef2e42bbb4c04643414922aa549140bd26 Mon Sep 17 00:00:00 2001
From: akulikov <akulikov@mfd.ru>
Date: Fri, 4 Aug 2023 13:32:27 +0300
Subject: [PATCH] http://jira.mfd.msk:8088/browse/CLS-358 company not found
 fixes

---
 .../reports/reports/bp/ExecutedDealReportBuilderCommon.java | 6 ++++++
 .../reports/reports/bp/UnfulfilledDealReportBuilder.java    | 6 ++++++
 .../reports/reports/ks/KSCommissionTradesReportBuilder.java | 6 ++++++
 .../reports/ks/KSRepCashRegisterSumsReportBuilder.java      | 6 ++++++
 .../reports/reports/ks/KSRepCashRegistersReportBuilder.java | 6 ++++++
 .../ks/KSRepDepoRegisterQuantitiesReportBuilder.java        | 6 ++++++
 .../reports/reports/ks/KSRepDepoRegistersReportBuilder.java | 6 ++++++
 7 files changed, 42 insertions(+)

diff --git a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/bp/ExecutedDealReportBuilderCommon.java b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/bp/ExecutedDealReportBuilderCommon.java
index 86cfaa538..44cc8b3da 100644
--- a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/bp/ExecutedDealReportBuilderCommon.java
+++ b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/bp/ExecutedDealReportBuilderCommon.java
@@ -61,6 +61,12 @@ public abstract class ExecutedDealReportBuilderCommon<P> extends CSVReportBuilde
         for (ExecutionFond executionFond : executionFonds) {
             try {
                 Company company = companyImdg.getSingleObjectByID(executionFond.getCompanyId());
+                if (company == null) {
+                    log.warn("For execution id = {} company with id = {} not found, execution was skipped",
+                            executionFond.getId(),
+                            executionFond.getCompanyId());
+                    continue;
+                }
                 if (!WorkflowStatus.Active.equalsByKey(company.getWorkflowStatus())) continue;
 
                 STrades sTrade = null;
diff --git a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/bp/UnfulfilledDealReportBuilder.java b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/bp/UnfulfilledDealReportBuilder.java
index 7c2a7c498..213ab2068 100644
--- a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/bp/UnfulfilledDealReportBuilder.java
+++ b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/bp/UnfulfilledDealReportBuilder.java
@@ -74,6 +74,12 @@ public class UnfulfilledDealReportBuilder extends CSVReportBuilder<SessionIdPara
         for (ExecutionFond executionFond : executionFonds) {
             try {
                 Company company = companyImdg.getSingleObjectByID(executionFond.getCompanyId());
+                if (company == null) {
+                    log.warn("For execution id = {} company with id = {} not found, execution was skipped",
+                            executionFond.getId(),
+                            executionFond.getCompanyId());
+                    continue;
+                }
                 if (!WorkflowStatus.Active.equalsByKey(company.getWorkflowStatus())) continue;;
 
                 STrades sTrade = sTradesImdg.getFirstObjectByFieldValues(
diff --git a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSCommissionTradesReportBuilder.java b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSCommissionTradesReportBuilder.java
index 7e2989930..4c272c82b 100644
--- a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSCommissionTradesReportBuilder.java
+++ b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSCommissionTradesReportBuilder.java
@@ -85,6 +85,12 @@ public class KSCommissionTradesReportBuilder extends CSVReportBuilder<EmptyParam
         for (Registry registry : registries) {
             try {
                 Company company = companyImdg.getSingleObjectByID(registry.getCompanyId());
+                if (company == null) {
+                    log.warn("For registry id = {} company with id = {} not found, registry was skipped",
+                            registry.getId(),
+                            registry.getCompanyId());
+                    continue;
+                }
                 if (!WorkflowStatus.Active.equalsByKey(company.getWorkflowStatus())) continue;
 
                 CompanySymbols companySymbols = companySymbolsImdg.getFirstObjectByFieldValues(
diff --git a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepCashRegisterSumsReportBuilder.java b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepCashRegisterSumsReportBuilder.java
index 5337fcbfc..8b777e12e 100644
--- a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepCashRegisterSumsReportBuilder.java
+++ b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepCashRegisterSumsReportBuilder.java
@@ -81,6 +81,12 @@ public class KSRepCashRegisterSumsReportBuilder extends CSVReportBuilder<EmptyPa
         for (Statement statement : statements) {
             try {
                 Company company = companyImdg.getSingleObjectByID(statement.getAddresseeId());
+                if (company == null) {
+                    log.warn("For statement id = {} company with id = {} not found, statement was skipped",
+                            statement.getId(),
+                            statement.getAddresseeId());
+                    continue;
+                }
                 if (!WorkflowStatus.Active.equalsByKey(company.getWorkflowStatus())) continue;
 
                 ImdgPredicateBuilder pbRegistry = registryImdg.predicateBuilder();
diff --git a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepCashRegistersReportBuilder.java b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepCashRegistersReportBuilder.java
index 1cd775d9f..01abf6ed6 100644
--- a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepCashRegistersReportBuilder.java
+++ b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepCashRegistersReportBuilder.java
@@ -84,6 +84,12 @@ public class KSRepCashRegistersReportBuilder extends CSVReportBuilder<EmptyParam
         for (Registry registry : registries) {
             try {
                 Company company = companyImdg.getSingleObjectByID(registry.getCompanyId());
+                if (company == null) {
+                    log.warn("For registry id = {} company with id = {} not found, registry was skipped",
+                            registry.getId(),
+                            registry.getCompanyId());
+                    continue;
+                }
                 if (!WorkflowStatus.Active.equalsByKey(company.getWorkflowStatus())) continue;
 
                 KSRepCashRegistersReport ksRepCashRegistersReport = new KSRepCashRegistersReport();
diff --git a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepDepoRegisterQuantitiesReportBuilder.java b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepDepoRegisterQuantitiesReportBuilder.java
index 4270d38af..f9966ecff 100644
--- a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepDepoRegisterQuantitiesReportBuilder.java
+++ b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepDepoRegisterQuantitiesReportBuilder.java
@@ -91,6 +91,12 @@ public class KSRepDepoRegisterQuantitiesReportBuilder extends CSVReportBuilder<E
         for (Statement statement : statements) {
             try {
                 Company company = companyImdg.getSingleObjectByID(statement.getAddresseeId());
+                if (company == null) {
+                    log.warn("For statement id = {} company with id = {} not found, statement was skipped",
+                            statement.getId(),
+                            statement.getAddresseeId());
+                    continue;
+                }
                 if (!WorkflowStatus.Active.equalsByKey(company.getWorkflowStatus())) continue;
 
                 ImdgPredicateBuilder pbRegistry = registryImdg.predicateBuilder();
diff --git a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepDepoRegistersReportBuilder.java b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepDepoRegistersReportBuilder.java
index 467faa7d0..39b0ecae9 100644
--- a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepDepoRegistersReportBuilder.java
+++ b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/reports/ks/KSRepDepoRegistersReportBuilder.java
@@ -82,6 +82,12 @@ public class KSRepDepoRegistersReportBuilder extends CSVReportBuilder<EmptyParam
         for (Registry registry : registries) {
             try {
                 Company company = companyImdg.getSingleObjectByID(registry.getCompanyId());
+                if (company == null) {
+                    log.warn("For registry id = {} company with id = {} not found, registry was skipped",
+                            registry.getId(),
+                            registry.getCompanyId());
+                    continue;
+                }
                 if (!WorkflowStatus.Active.equalsByKey(company.getWorkflowStatus())) continue;
 
                 KSRepDepoRegistersReport ksRepDepoRegistersReport = new KSRepDepoRegistersReport();