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

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

Browse source
This commit is contained in:
ialbert 2026-07-08 13:11:19 +03:00
parent 56bc00bcad
commit 0e3cdcac4c
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
clearing-parent/xml-exporter/src/main/java/ru/spcex/clearing/xml/exporter/logic/stages/PrepareXMLFile.java
View file

@ -85,7 +85,7 @@ public class PrepareXMLFile implements InitializingBean {
if (template.needSftpFiles()) {
xmlFile = new File(template.getFileName(resultContainer, files));
} else {
AtomicInteger counter = getOrInitCounter(table, template);
AtomicInteger counter = getOrInitCounter(resultContainer, template);
xmlFile = new File(template.getFileName(resultContainer, counter));
}
if (sftpConnectionError) {
@ -109,16 +109,24 @@ public class PrepareXMLFile implements InitializingBean {
return StageResult.OK;
}
private AtomicInteger getOrInitCounter(Table table, FilenameTemplate template) {
private AtomicInteger getOrInitCounter(ResultContainer resultContainer, FilenameTemplate template) {
LocalDate today = LocalDate.now();
if (!today.equals(lastCounterDate)) {
counters.clear();
this.lastCounterDate = today;
}
Table table = resultContainer.getTableForExport();
return counters.computeIfAbsent(table, k -> {
imdgProvider.waitAvailable();
Imdg<SpcexObjectBase> imdg = imdgProvider.getImdg(k.getHazelcastMapName(), SpcexObjectBase.class);
ImdgPredicate counterPredicate = template.counterPredicate(imdg.predicateBuilder());
var pb = imdg.predicateBuilder();
ImdgPredicate counterPredicate = template.counterPredicate(pb);
if (resultContainer.getGroupId() != null) {
counterPredicate = pb.and(
counterPredicate,
pb.not(pb.equals("generationId", resultContainer.getGroupId()))
);
}
Collection<SpcexObjectBase> items = imdg.getCollectionObjectsByPredicate(counterPredicate);
return new AtomicInteger(items.size());
}