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

http://jira.mfd.msk:8088/browse/CLS-313 todo issue

Browse source
This commit is contained in:
akulikov 2023-07-03 20:08:07 +03:00
parent 8548c6a8f7
commit d253f9e1ff
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -103,6 +103,11 @@ 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); gateway.sendToSftp(dbfFile);
} }
writeOk = true; writeOk = true;
@ -118,6 +123,10 @@ 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 && !emptyMap) {
// gateway.sendToSftp(dbfFile);
// }
} }
return StageResult.OK; return StageResult.OK;