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

dbf-importer swt-importer Забирать и обрабатывать файлы в порядке времени изменения на sftp

Browse source
This commit is contained in:
AKurakin 2023-11-16 12:43:44 +03:00
parent fac5dca462
commit 10d8803651
4 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/config/SFTPConfig.java
View file

@ -22,6 +22,7 @@ import org.springframework.scheduling.support.PeriodicTrigger;
import ru.spcex.clearing.dbf.importer.config.settings.ImportDBFServiceSettings; import ru.spcex.clearing.dbf.importer.config.settings.ImportDBFServiceSettings;
import java.io.File; import java.io.File;
import java.util.Comparator;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@Configuration @Configuration
@ -60,6 +61,8 @@ public class SFTPConfig {
fileSync.setTemporaryFileSuffix(".tmp"); fileSync.setTemporaryFileSuffix(".tmp");
fileSync.setRemoteDirectory(settings.getStore().getSftpIn().getSftpSrcDir()); fileSync.setRemoteDirectory(settings.getStore().getSftpIn().getSftpSrcDir());
fileSync.setFilter(new AcceptAllFileListFilter<>()); fileSync.setFilter(new AcceptAllFileListFilter<>());
fileSync.setPreserveTimestamp(true);
fileSync.setComparator(Comparator.comparingInt(f -> f.getAttrs().getMTime()));
return fileSync; return fileSync;
} }

1
clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/services/FileChecker.java
View file

@ -48,6 +48,7 @@ public class FileChecker {
List<File> resultFiles = new LinkedList<>(); List<File> resultFiles = new LinkedList<>();
if (dbfFiles != null && dbfFiles.length >= 1) { if (dbfFiles != null && dbfFiles.length >= 1) {
Arrays.sort(dbfFiles, Comparator.comparingLong(File::lastModified));
resultFiles.addAll(Arrays.asList(dbfFiles)); resultFiles.addAll(Arrays.asList(dbfFiles));
} }

3
clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/config/SFTPConfig.java
View file

@ -22,6 +22,7 @@ import org.springframework.scheduling.support.PeriodicTrigger;
import ru.spcex.clearing.swt.importer.config.settings.ImportSWTServiceSettings; import ru.spcex.clearing.swt.importer.config.settings.ImportSWTServiceSettings;
import java.io.File; import java.io.File;
import java.util.Comparator;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@Configuration @Configuration
@ -60,6 +61,8 @@ public class SFTPConfig {
fileSync.setTemporaryFileSuffix(".tmp"); fileSync.setTemporaryFileSuffix(".tmp");
fileSync.setRemoteDirectory(settings.getStore().getSftpIn().getSftpSrcDir()); fileSync.setRemoteDirectory(settings.getStore().getSftpIn().getSftpSrcDir());
fileSync.setFilter(new AcceptAllFileListFilter<>()); fileSync.setFilter(new AcceptAllFileListFilter<>());
fileSync.setPreserveTimestamp(true);
fileSync.setComparator(Comparator.comparingInt(f -> f.getAttrs().getMTime()));
return fileSync; return fileSync;
} }

1
clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/services/FileChecker.java
View file

@ -54,6 +54,7 @@ public class FileChecker {
List<File> resultFiles = new LinkedList<>(); List<File> resultFiles = new LinkedList<>();
if (swtFiles != null && swtFiles.length >= 1) { if (swtFiles != null && swtFiles.length >= 1) {
Arrays.sort(swtFiles, Comparator.comparingLong(File::lastModified));
resultFiles.addAll(Arrays.asList(swtFiles)); resultFiles.addAll(Arrays.asList(swtFiles));
} }