http://jira.mfd.msk:8088/browse/CLS-1055 переход через день
This commit is contained in:
parent
8c1e57accd
commit
56287f6a8e
1 changed files with 7 additions and 0 deletions
|
|
@ -4,6 +4,7 @@ import java.io.File;
|
|||
import java.io.IOException;
|
||||
import java.nio.file.Files;
|
||||
import java.nio.file.Path;
|
||||
import java.time.LocalDate;
|
||||
import java.time.LocalDateTime;
|
||||
import java.time.format.DateTimeFormatter;
|
||||
import java.util.ArrayList;
|
||||
|
|
@ -41,6 +42,7 @@ public class PrepareXMLFile implements InitializingBean {
|
|||
private final SFTPConfig.XmlGateway gateway;
|
||||
private final ImdgProvider imdgProvider;
|
||||
private final Map<Table, AtomicInteger> counters = new HashMap<>();
|
||||
private LocalDate lastCounterDate;
|
||||
|
||||
public PrepareXMLFile(ImdgProvider imdgProvider,
|
||||
ExportXMLServiceSettings settings,
|
||||
|
|
@ -108,6 +110,11 @@ public class PrepareXMLFile implements InitializingBean {
|
|||
}
|
||||
|
||||
private AtomicInteger getOrInitCounter(Table table, FilenameTemplate template) {
|
||||
LocalDate today = LocalDate.now();
|
||||
if (!today.equals(lastCounterDate)) {
|
||||
counters.clear();
|
||||
this.lastCounterDate = today;
|
||||
}
|
||||
return counters.computeIfAbsent(table, k -> {
|
||||
imdgProvider.waitAvailable();
|
||||
Imdg<SpcexObjectBase> imdg = imdgProvider.getImdg(k.getHazelcastMapName(), SpcexObjectBase.class);
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue