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

http://jira.mfd.msk:8088/browse/CLS-313 fix send sftp

Browse source
This commit is contained in:
akulikov 2023-07-03 20:20:44 +03:00
parent d253f9e1ff
commit 132a3e7096
1 changed files with 3 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
clearing-parent/dbf-exporter/src/main/java/ru/spcex/clearing/dbf/exporter/logic/stages/ExportFromHazelcast.java
View file

@ -103,12 +103,6 @@ public class ExportFromHazelcast extends Stage implements InitializingBean {
else if (value instanceof SDf56 sDf56Value) values = s_df56_converter.toObjectArray(sDf56Value); else if (value instanceof SDf56 sDf56Value) values = s_df56_converter.toObjectArray(sDf56Value);
else throw new Exception("Get unknown object from imdg. Class: " + value.getClass().getSimpleName()); else throw new Exception("Get unknown object from imdg. Class: " + value.getClass().getSimpleName());
dbfWriter.addRecord(values); dbfWriter.addRecord(values);
// todo баг. фиксить пока не стал. вынести к todo ниже.
// при такой отправке файл отправляется с каждой записанной строчкой, и выглядит записанным.
// однако поскольку не был достигнут блок finally, не вызывается close() для dbfWriter,
// поэтому файл отправляется по sftp, постоянно там перезаписывается и в конце оказывается без
// валидного заголовка.
gateway.sendToSftp(dbfFile);
} }
writeOk = true; writeOk = true;
emptyMap = tableRows.isEmpty(); emptyMap = tableRows.isEmpty();
@ -123,10 +117,9 @@ public class ExportFromHazelcast extends Stage implements InitializingBean {
log.warn("Can't delete file {}", resultContainer.getFileForExport().getName()); log.warn("Can't delete file {}", resultContainer.getFileForExport().getName());
} }
} }
// TODO send to sftp if (writeOk) {
// if (writeOk && !emptyMap) { gateway.sendToSftp(dbfFile);
// gateway.sendToSftp(dbfFile); }
// }
} }
return StageResult.OK; return StageResult.OK;