From b36ea99b2890a0cff0b901b46f79f58c83e8a1f9 Mon Sep 17 00:00:00 2001 From: ialbert Date: Tue, 25 Jul 2023 19:33:30 +0300 Subject: [PATCH] =?UTF-8?q?=D0=B2=D1=8B=D0=BD=D0=B5=D1=81=20=D0=BD=D0=B0?= =?UTF-8?q?=D1=81=D1=82=D1=80=D0=BE=D0=B9=D0=BA=D0=B8=20=D1=83=D0=B4=D0=B0?= =?UTF-8?q?=D0=BB=D0=B5=D0=BD=D0=BD=D0=BE=D0=B9=20SFTP=20=D0=BF=D0=B0?= =?UTF-8?q?=D0=BF=D0=BA=D0=B8=20=D1=81=20=D1=84=D0=B0=D0=B9=D0=BB=D0=B0?= =?UTF-8?q?=D0=BC=D0=B8=20=D0=B2=20=D0=BE=D1=82=D0=B4=D0=B5=D0=BB=D1=8C?= =?UTF-8?q?=D0=BD=D1=8B=D0=B9=20=D0=BA=D0=BB=D0=B0=D1=81=D1=81=20=D1=82?= =?UTF-8?q?=D0=B5=D0=BF=D0=B5=D1=80=D1=8C=20=D0=BC=D0=BE=D0=B4=D1=83=D0=BB?= =?UTF-8?q?=D1=8C=20=D0=BC=D0=BE=D0=B6=D0=BD=D0=BE=20=D0=B7=D0=B0=D0=BF?= =?UTF-8?q?=D1=83=D1=81=D1=82=D0=B8=D1=82=D1=8C=20=D0=B1=D0=B5=D0=B7=20SFT?= =?UTF-8?q?P=20(=D0=BF=D1=80=D0=B8=20=D0=BE=D1=82=D1=81=D1=83=D1=82=D1=81?= =?UTF-8?q?=D1=82=D0=B2=D0=B8=D0=B8=20=D1=81=D0=BE=D0=BE=D1=82=D0=B2=D0=B5?= =?UTF-8?q?=D1=82=D1=81=D1=82=D0=B2=D1=83=D1=8E=D1=89=D0=B8=D1=85=20=D0=BD?= =?UTF-8?q?=D0=B0=D1=81=D1=82=D1=80=D0=BE=D0=B5=D0=BA)?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dbf/importer/config/SFTPConfig.java | 12 +++-- .../dbf/importer/config/settings/Store.java | 49 +++---------------- .../src/main/resources/application.properties | 10 ++-- .../swt/importer/config/SFTPConfig.java | 12 ++--- .../swt/importer/config/settings/Store.java | 49 +++---------------- .../src/main/resources/application.properties | 10 ++-- .../config/SftpInboundFolderSetting.java | 49 +++++++++++++++++++ 7 files changed, 86 insertions(+), 105 deletions(-) create mode 100644 platform-parent/platform-utils/src/main/java/ru/spcex/platform/utils/config/SftpInboundFolderSetting.java diff --git a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/config/SFTPConfig.java b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/config/SFTPConfig.java index 57ff79485..90eb87d67 100644 --- a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/config/SFTPConfig.java +++ b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/config/SFTPConfig.java @@ -4,6 +4,7 @@ import com.jcraft.jsch.ChannelSftp; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.integration.annotation.InboundChannelAdapter; @@ -24,6 +25,7 @@ import java.io.File; import java.util.concurrent.TimeUnit; @Configuration +@ConditionalOnProperty(value="import-dbf-service.store.sftp-in.sftp-src-dir") public class SFTPConfig { private final Logger log = LoggerFactory.getLogger(getClass()); private final ImportDBFServiceSettings settings; @@ -36,10 +38,10 @@ public class SFTPConfig { @Bean public SessionFactory sftpSessionFactory() { DefaultSftpSessionFactory factory = new DefaultSftpSessionFactory(true); - factory.setHost(settings.getStore().getServerIp()); - factory.setPort(settings.getStore().getServerPort()); - factory.setUser(settings.getStore().getUser()); - factory.setPassword(settings.getStore().getPassword()); + factory.setHost(settings.getStore().getSftpIn().getServerIp()); + factory.setPort(settings.getStore().getSftpIn().getServerPort()); + factory.setUser(settings.getStore().getSftpIn().getUser()); + factory.setPassword(settings.getStore().getSftpIn().getPassword()); factory.setAllowUnknownKeys(true); return new CachingSessionFactory<>(factory); } @@ -56,7 +58,7 @@ public class SFTPConfig { SftpInboundFileSynchronizer fileSync = new SftpInboundFileSynchronizer(sftpSessionFactory()); fileSync.setDeleteRemoteFiles(true); fileSync.setTemporaryFileSuffix(".tmp"); - fileSync.setRemoteDirectory(settings.getStore().getSftpSrcDir()); + fileSync.setRemoteDirectory(settings.getStore().getSftpIn().getSftpSrcDir()); fileSync.setFilter(new AcceptAllFileListFilter<>()); return fileSync; } diff --git a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/config/settings/Store.java b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/config/settings/Store.java index 07a7cbe35..a600f4717 100644 --- a/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/config/settings/Store.java +++ b/clearing-parent/dbf-importer/src/main/java/ru/spcex/clearing/dbf/importer/config/settings/Store.java @@ -1,5 +1,7 @@ package ru.spcex.clearing.dbf.importer.config.settings; +import ru.spcex.platform.utils.config.SftpInboundFolderSetting; + public class Store { private String srcDir; @@ -7,12 +9,7 @@ public class Store { private String outDirError; private boolean deleteSrcFiles = true; //sftp settings - private String sftpSrcDir; - private String user; - private String password; - private String serverIp; - private int serverPort; - + private SftpInboundFolderSetting sftpIn; public String getSrcDir() { return srcDir; } @@ -45,43 +42,11 @@ public class Store { this.outDirError = outDirError; } - public String getUser() { - return user; + public SftpInboundFolderSetting getSftpIn() { + return sftpIn; } - public void setUser(String user) { - this.user = user; - } - - public String getPassword() { - return password; - } - - public void setPassword(String password) { - this.password = password; - } - - public String getServerIp() { - return serverIp; - } - - public void setServerIp(String serverIp) { - this.serverIp = serverIp; - } - - public int getServerPort() { - return serverPort; - } - - public void setServerPort(int serverPort) { - this.serverPort = serverPort; - } - - public String getSftpSrcDir() { - return sftpSrcDir; - } - - public void setSftpSrcDir(String sftpSrcDir) { - this.sftpSrcDir = sftpSrcDir; + public void setSftpIn(SftpInboundFolderSetting sftpIn) { + this.sftpIn = sftpIn; } } diff --git a/clearing-parent/dbf-importer/src/main/resources/application.properties b/clearing-parent/dbf-importer/src/main/resources/application.properties index f7b835461..d9da26709 100644 --- a/clearing-parent/dbf-importer/src/main/resources/application.properties +++ b/clearing-parent/dbf-importer/src/main/resources/application.properties @@ -14,11 +14,11 @@ import-dbf-service.common.insert-batch-size=100 import-dbf-service.common.threads-count=10 #sftpSrcDir -import-dbf-service.store.sftp-src-dir=clearing_importer_sftp -import-dbf-service.store.user=user -import-dbf-service.store.password=********* -import-dbf-service.store.server-ip=127.0.0.1 -import-dbf-service.store.server-port=22 +import-dbf-service.store.sftp-in.sftp-src-dir=clearing_importer_sftp +import-dbf-service.store.sftp-in.user=user +import-dbf-service.store.sftp-in.password=********* +import-dbf-service.store.sftp-in.server-ip=127.0.0.1 +import-dbf-service.store.sftp-in.server-port=22 import-dbf-service.hazelcast.cluster-members=10.200.200.181:5701 import-dbf-service.hazelcast.login=dev diff --git a/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/config/SFTPConfig.java b/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/config/SFTPConfig.java index e8e24167a..c0255fa1a 100644 --- a/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/config/SFTPConfig.java +++ b/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/config/SFTPConfig.java @@ -25,7 +25,7 @@ import java.io.File; import java.util.concurrent.TimeUnit; @Configuration -@ConditionalOnProperty(value="import-swt-service.store.sftp-src-dir") +@ConditionalOnProperty(value="import-swt-service.store.sftp-in.sftp-src-dir") public class SFTPConfig { private final Logger log = LoggerFactory.getLogger(getClass()); private final ImportSWTServiceSettings settings; @@ -38,10 +38,10 @@ public class SFTPConfig { @Bean public SessionFactory sftpSessionFactory() { DefaultSftpSessionFactory factory = new DefaultSftpSessionFactory(true); - factory.setHost(settings.getStore().getServerIp()); - factory.setPort(settings.getStore().getServerPort()); - factory.setUser(settings.getStore().getUser()); - factory.setPassword(settings.getStore().getPassword()); + factory.setHost(settings.getStore().getSftpIn().getServerIp()); + factory.setPort(settings.getStore().getSftpIn().getServerPort()); + factory.setUser(settings.getStore().getSftpIn().getUser()); + factory.setPassword(settings.getStore().getSftpIn().getPassword()); factory.setAllowUnknownKeys(true); return new CachingSessionFactory<>(factory); } @@ -58,7 +58,7 @@ public class SFTPConfig { SftpInboundFileSynchronizer fileSync = new SftpInboundFileSynchronizer(sftpSessionFactory()); fileSync.setDeleteRemoteFiles(true); fileSync.setTemporaryFileSuffix(".tmp"); - fileSync.setRemoteDirectory(settings.getStore().getSftpSrcDir()); + fileSync.setRemoteDirectory(settings.getStore().getSftpIn().getSftpSrcDir()); fileSync.setFilter(new AcceptAllFileListFilter<>()); return fileSync; } diff --git a/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/config/settings/Store.java b/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/config/settings/Store.java index af506b8e1..8f08a93b7 100644 --- a/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/config/settings/Store.java +++ b/clearing-parent/swt-importer/src/main/java/ru/spcex/clearing/swt/importer/config/settings/Store.java @@ -1,17 +1,14 @@ package ru.spcex.clearing.swt.importer.config.settings; +import ru.spcex.platform.utils.config.SftpInboundFolderSetting; + public class Store { private String srcDir; private String outDir; private String outDirError; private boolean deleteSrcFiles = true; - //sftp settings - private String sftpSrcDir; - private String user; - private String password; - private String serverIp; - private int serverPort; + private SftpInboundFolderSetting sftpIn; public String getSrcDir() { return srcDir; @@ -45,43 +42,11 @@ public class Store { this.outDirError = outDirError; } - public String getSftpSrcDir() { - return sftpSrcDir; + public SftpInboundFolderSetting getSftpIn() { + return sftpIn; } - public void setSftpSrcDir(String sftpSrcDir) { - this.sftpSrcDir = sftpSrcDir; - } - - public String getUser() { - return user; - } - - public void setUser(String user) { - this.user = user; - } - - public String getPassword() { - return password; - } - - public void setPassword(String password) { - this.password = password; - } - - public String getServerIp() { - return serverIp; - } - - public void setServerIp(String serverIp) { - this.serverIp = serverIp; - } - - public int getServerPort() { - return serverPort; - } - - public void setServerPort(int serverPort) { - this.serverPort = serverPort; + public void setSftpIn(SftpInboundFolderSetting sftpIn) { + this.sftpIn = sftpIn; } } diff --git a/clearing-parent/swt-importer/src/main/resources/application.properties b/clearing-parent/swt-importer/src/main/resources/application.properties index a12532494..0fe43877d 100644 --- a/clearing-parent/swt-importer/src/main/resources/application.properties +++ b/clearing-parent/swt-importer/src/main/resources/application.properties @@ -10,11 +10,11 @@ import-swt-service.store.out-dir=clearing-parent/swt-importer/src/test/java/ru/s import-swt-service.store.out-dir-error=clearing-parent/swt-importer/src/test/java/ru/spcex/clearing/swt/importer/files/importer/error/ #sftpSrcDir -import-swt-service.store.sftp-src-dir=/path/to/sftp/folder -import-swt-service.store.user=user -import-swt-service.store.password=********* -import-swt-service.store.server-ip=127.0.0.1 -import-swt-service.store.server-port=22 +import-swt-service.store.sftp-in.sftp-src-dir=/path/to/sftp/folder +import-swt-service.store.sftp-in.user=user +import-swt-service.store.sftp-in.password=********* +import-swt-service.store.sftp-in.server-ip=127.0.0.1 +import-swt-service.store.sftp-in.server-port=22 import-swt-service.common.encoding-source=cp866 import-swt-service.common.insert-batch-size=100 diff --git a/platform-parent/platform-utils/src/main/java/ru/spcex/platform/utils/config/SftpInboundFolderSetting.java b/platform-parent/platform-utils/src/main/java/ru/spcex/platform/utils/config/SftpInboundFolderSetting.java new file mode 100644 index 000000000..706cf023f --- /dev/null +++ b/platform-parent/platform-utils/src/main/java/ru/spcex/platform/utils/config/SftpInboundFolderSetting.java @@ -0,0 +1,49 @@ +package ru.spcex.platform.utils.config; + +public class SftpInboundFolderSetting { + private String sftpSrcDir; + private String user; + private String password; + private String serverIp; + private int serverPort; + + public String getSftpSrcDir() { + return sftpSrcDir; + } + + public void setSftpSrcDir(String sftpSrcDir) { + this.sftpSrcDir = sftpSrcDir; + } + + public String getUser() { + return user; + } + + public void setUser(String user) { + this.user = user; + } + + public String getPassword() { + return password; + } + + public void setPassword(String password) { + this.password = password; + } + + public String getServerIp() { + return serverIp; + } + + public void setServerIp(String serverIp) { + this.serverIp = serverIp; + } + + public int getServerPort() { + return serverPort; + } + + public void setServerPort(int serverPort) { + this.serverPort = serverPort; + } +}