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

http://jira.mfd.msk:8088/browse/CLS-929

Browse source
This commit is contained in:
etreschenkov 2026-02-13 13:25:10 +03:00
parent e14f7872d9
commit f02c2eb691
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/services/ReportService.java
View file

@ -266,8 +266,8 @@ public class ReportService extends QueueConsumerV2 implements InitializingBean {
} }
Map<File, ReportInfo> outFiles = createReportsForTask(sessionIds, reportBuildersForGREP.values()); Map<File, ReportInfo> outFiles = createReportsForTask(sessionIds, reportBuildersForGREP.values());
sendReportsToGateway(sessionIds, outFiles, ReportType.REPORT_KS_TMP.getKey());
sendFilesToSftp(outFiles.keySet()); sendFilesToSftp(outFiles.keySet());
sendReportsToGateway(sessionIds, outFiles, ReportType.REPORT_KS_TMP.getKey());
} catch (Exception e) { } catch (Exception e) {
log.error("Unexpected exception", e); log.error("Unexpected exception", e);
} }
@ -305,9 +305,9 @@ public class ReportService extends QueueConsumerV2 implements InitializingBean {
outFilesWithReportType_PFX64.put(reportFile, reportInfo); outFilesWithReportType_PFX64.put(reportFile, reportInfo);
} }
} }
sendFilesToSftp(outFiles.keySet());
sendReportsToGateway(sessionIds, outFilesWithReportType_PFX64, ReportType.PFX64.getKey()); sendReportsToGateway(sessionIds, outFilesWithReportType_PFX64, ReportType.PFX64.getKey());
sendReportsToGateway(sessionIds, outFilesWithReportType_PFX65, ReportType.PFX65.getKey()); sendReportsToGateway(sessionIds, outFilesWithReportType_PFX65, ReportType.PFX65.getKey());
sendFilesToSftp(outFiles.keySet());
} catch (Exception e) { } catch (Exception e) {
log.error("Unexpected exception", e); log.error("Unexpected exception", e);
} }
@ -328,8 +328,8 @@ public class ReportService extends QueueConsumerV2 implements InitializingBean {
} }
Map<File, ReportInfo> outFiles = createReportsForTask(sessionIds, reportBuildersForGREF.values()); Map<File, ReportInfo> outFiles = createReportsForTask(sessionIds, reportBuildersForGREF.values());
sendReportsToGateway(sessionIds, outFiles, ReportType.REPORT_KS_FINAL.getKey());
sendFilesToSftp(outFiles.keySet()); sendFilesToSftp(outFiles.keySet());
sendReportsToGateway(sessionIds, outFiles, ReportType.REPORT_KS_FINAL.getKey());
} catch (Exception e) { } catch (Exception e) {
log.error("Unexpected exception", e); log.error("Unexpected exception", e);
} }
@ -346,8 +346,8 @@ public class ReportService extends QueueConsumerV2 implements InitializingBean {
Map<File, ReportInfo> outFiles = createReportsForTask(List.of(), reportBuildersForGREC.values()); Map<File, ReportInfo> outFiles = createReportsForTask(List.of(), reportBuildersForGREC.values());
sendReportsToGateway(List.of(), outFiles, ReportType.REPORT_KS_OUTER.getKey());
sendFilesToSftp(outFiles.keySet()); sendFilesToSftp(outFiles.keySet());
sendReportsToGateway(List.of(), outFiles, ReportType.REPORT_KS_OUTER.getKey());
} catch (Exception e) { } catch (Exception e) {
log.error("Unexpected exception", e); log.error("Unexpected exception", e);
} }
@ -364,8 +364,8 @@ public class ReportService extends QueueConsumerV2 implements InitializingBean {
Map<File, ReportInfo> outFiles = createReportsForTask(List.of(), reportBuildersForCX84.values()); Map<File, ReportInfo> outFiles = createReportsForTask(List.of(), reportBuildersForCX84.values());
sendReportsToGateway(List.of(), outFiles, ReportType.REPORT_KS_VALUE_OUTER.getKey());
sendFilesToSftp(outFiles.keySet()); sendFilesToSftp(outFiles.keySet());
sendReportsToGateway(List.of(), outFiles, ReportType.REPORT_KS_VALUE_OUTER.getKey());
} catch (Exception e) { } catch (Exception e) {
log.error("Unexpected exception", e); log.error("Unexpected exception", e);
} }