diff --git a/.classpath b/.classpath
new file mode 100644
index 0000000..653dfd7
--- /dev/null
+++ b/.classpath
@@ -0,0 +1,57 @@
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
diff --git a/.project b/.project
new file mode 100644
index 0000000..9f52b4d
--- /dev/null
+++ b/.project
@@ -0,0 +1,34 @@
+
+
+ SSHFileToCbs_PROD
+
+
+
+
+
+ org.eclipse.jdt.core.javabuilder
+
+
+
+
+ org.eclipse.m2e.core.maven2Builder
+
+
+
+
+
+ org.eclipse.jdt.core.javanature
+ org.eclipse.m2e.core.maven2Nature
+
+
+
+ 1754758620396
+
+ 30
+
+ org.eclipse.core.resources.regexFilterMatcher
+ node_modules|\.git|__CREATED_BY_JAVA_LANGUAGE_SERVER__
+
+
+
+
diff --git a/.settings/org.eclipse.core.resources.prefs b/.settings/org.eclipse.core.resources.prefs
new file mode 100644
index 0000000..839d647
--- /dev/null
+++ b/.settings/org.eclipse.core.resources.prefs
@@ -0,0 +1,5 @@
+eclipse.preferences.version=1
+encoding//src/main/java=UTF-8
+encoding//src/main/resources=UTF-8
+encoding//src/test/java=UTF-8
+encoding/=UTF-8
diff --git a/.settings/org.eclipse.jdt.apt.core.prefs b/.settings/org.eclipse.jdt.apt.core.prefs
new file mode 100644
index 0000000..d4313d4
--- /dev/null
+++ b/.settings/org.eclipse.jdt.apt.core.prefs
@@ -0,0 +1,2 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.apt.aptEnabled=false
diff --git a/.settings/org.eclipse.jdt.core.prefs b/.settings/org.eclipse.jdt.core.prefs
new file mode 100644
index 0000000..1b6e1ef
--- /dev/null
+++ b/.settings/org.eclipse.jdt.core.prefs
@@ -0,0 +1,9 @@
+eclipse.preferences.version=1
+org.eclipse.jdt.core.compiler.codegen.targetPlatform=1.8
+org.eclipse.jdt.core.compiler.compliance=1.8
+org.eclipse.jdt.core.compiler.problem.enablePreviewFeatures=disabled
+org.eclipse.jdt.core.compiler.problem.forbiddenReference=warning
+org.eclipse.jdt.core.compiler.problem.reportPreviewFeatures=ignore
+org.eclipse.jdt.core.compiler.processAnnotations=disabled
+org.eclipse.jdt.core.compiler.release=disabled
+org.eclipse.jdt.core.compiler.source=1.8
diff --git a/.settings/org.eclipse.m2e.core.prefs b/.settings/org.eclipse.m2e.core.prefs
new file mode 100644
index 0000000..f897a7f
--- /dev/null
+++ b/.settings/org.eclipse.m2e.core.prefs
@@ -0,0 +1,4 @@
+activeProfiles=
+eclipse.preferences.version=1
+resolveWorkspaceProjects=true
+version=1
diff --git a/src/main/java/com/sendFile/SendLocalfile.java b/src/main/java/com/sendFile/SendLocalfile.java
index 29c1b34..e82e9a7 100644
--- a/src/main/java/com/sendFile/SendLocalfile.java
+++ b/src/main/java/com/sendFile/SendLocalfile.java
@@ -5,84 +5,83 @@ import com.sendFile.protocol.FTP.FTPProtocol;
import com.sendFile.protocol.SSH.SSHProtocol;
public class SendLocalfile {
- String user;
- String password;
- String hostUcb;
- String hostNabard;
- String local_folder_path;
- String archive_path;
- String remote_file_path;
- String transfer_protocol;
- int port;
+ String user;
+ String password;
+ String hostUcb;
+ String hostNabard;
+ String local_folder_path;
+ String archive_path;
+ String remote_file_path;
+ String transfer_protocol;
+ int port;
- public SendLocalfile(
- String user,
- String password,
- String hostUcb,
- String hostNabard,
- String local_folder_path,
- String remote_file_path,
- String transfer_protocol,
- int port,
- String archivePath) {
- this.user = user;
- this.password = password;
- this.hostUcb = hostUcb;
- this.hostNabard = hostNabard;
- this.local_folder_path = local_folder_path;
- this.remote_file_path = remote_file_path;
- this.transfer_protocol = transfer_protocol;
- this.port = port;
- this.archive_path = archivePath;
- }
-
- public void sendFiles() {
- File folder = new File(this.local_folder_path);
- File[] listOfFiles = folder.listFiles();
-
- for (File file : listOfFiles) {
- if (file.isFile()) {
- System.out.println("Going to send file: " + file.getAbsolutePath());
- String bankCode = file.getName().split("-")[0];
- String bankHost = "";
- if(bankCode.equals("0005") || bankCode.equals("0021")) {
- bankHost = hostNabard;
- } else {
- bankHost = hostUcb;
- }
-
-
- if (this.transfer_protocol.equals("SSH")) {
-
- SSHProtocol ssh =
- new SSHProtocol(
- this.user,
- this.password,
- bankHost,
- this.port,
- file.getAbsolutePath(),
- this.remote_file_path,
- file.getName(),
- this.archive_path);
- ssh.sendFileSSH();
- } else if (this.transfer_protocol.equals("FTP")) {
-
- FTPProtocol ftp =
- new FTPProtocol(
- this.user,
- this.password,
- bankHost,
- this.port,
- file.getAbsolutePath(),
- this.remote_file_path,
- file.getName(),
- this.archive_path);
- ftp.sendFileFTP();
- } else {
-
- System.out.println("Invalid TRANSFER_PROTOCOL. Must be one of FTP or SSH");
- }
- }
+ public SendLocalfile(
+ String user,
+ String password,
+ String hostUcb,
+ String hostNabard,
+ String local_folder_path,
+ String remote_file_path,
+ String transfer_protocol,
+ int port,
+ String archivePath) {
+ this.user = user;
+ this.password = password;
+ this.hostUcb = hostUcb;
+ this.hostNabard = hostNabard;
+ this.local_folder_path = local_folder_path;
+ this.remote_file_path = remote_file_path;
+ this.transfer_protocol = transfer_protocol;
+ this.port = port;
+ this.archive_path = archivePath;
+ }
+
+ public void sendFiles() {
+ File folder = new File(this.local_folder_path);
+ File[] listOfFiles = folder.listFiles();
+
+ for (File file : listOfFiles) {
+ if (file.isFile()) {
+ System.out.println("Going to send file: " + file.getAbsolutePath());
+ String bankCode = file.getName().split("-")[0];
+ String bankHost = "";
+ if (bankCode.equals("0005") || bankCode.equals("0021") || bankCode.equals("0016")
+ || bankCode.equals("0018") || bankCode.equals("0001") || bankCode.equals("0004")
+ || bankCode.equals("0007")) {
+ bankHost = hostNabard;
+ } else {
+ bankHost = hostUcb;
+ }
+
+ if (this.transfer_protocol.equals("SSH")) {
+
+ SSHProtocol ssh = new SSHProtocol(
+ this.user,
+ this.password,
+ bankHost,
+ this.port,
+ file.getAbsolutePath(),
+ this.remote_file_path,
+ file.getName(),
+ this.archive_path);
+ ssh.sendFileSSH();
+ } else if (this.transfer_protocol.equals("FTP")) {
+
+ FTPProtocol ftp = new FTPProtocol(
+ this.user,
+ this.password,
+ bankHost,
+ this.port,
+ file.getAbsolutePath(),
+ this.remote_file_path,
+ file.getName(),
+ this.archive_path);
+ ftp.sendFileFTP();
+ } else {
+
+ System.out.println("Invalid TRANSFER_PROTOCOL. Must be one of FTP or SSH");
+ }
+ }
+ }
}
- }
}
diff --git a/src/main/java/com/sendFile/protocol/SSH/SSHProtocol.java b/src/main/java/com/sendFile/protocol/SSH/SSHProtocol.java
index 0b78fe2..2a78dc8 100644
--- a/src/main/java/com/sendFile/protocol/SSH/SSHProtocol.java
+++ b/src/main/java/com/sendFile/protocol/SSH/SSHProtocol.java
@@ -9,157 +9,157 @@ import java.util.Vector;
import com.moveFile.Movefile;
public class SSHProtocol {
- String user;
- String password;
- String host;
- int port;
- String local_fileName;
- String remote_filePath;
- String remote_fileName;
- String archive_path;
- String local_folder_path_bkp;
+ String user;
+ String password;
+ String host;
+ int port;
+ String local_fileName;
+ String remote_filePath;
+ String remote_fileName;
+ String archive_path;
+ String local_folder_path_bkp;
- public SSHProtocol(
- String user,
- String password,
- String host,
- int port,
- String local_fileName,
- String remote_filePath,
- String remote_fileName,
- String archive_path) {
- this.user = user;
- this.password = password;
- this.host = host;
- this.port = port;
- this.local_fileName = local_fileName;
- this.remote_filePath = remote_filePath;
- this.remote_fileName = remote_fileName;
- this.archive_path = archive_path;
- }
-
- public void sendFileSSH() {
- try {
- System.out.println("Going to SEND files from remote Server via SSH");
- JSch jsch = new JSch();
- System.out.println(
- "Creating SSH Session: user@host:port |--->"
- + this.user
- + "@"
- + this.host
- + ":"
- + this.port);
- Session session = jsch.getSession(this.user, this.host, this.port);
- session.setPassword(this.password);
-
- Properties config = new Properties();
- config.put("StrictHostKeyChecking", "no");
- session.setConfig(config);
- System.out.println("Establishing Connection...");
- session.connect();
- System.out.println("Connection established.");
- System.out.println("Creating SFTP Channel.");
- ChannelSftp sftpChannel = (ChannelSftp) session.openChannel("sftp");
- sftpChannel.connect();
- System.out.println("SFTP Channel created.");
- System.out.println(
- "SFTP -- Local File Name: "
- + this.local_fileName
- + " Remote File Name: "
- + this.remote_fileName);
-
- String[] fileTokens = this.remote_fileName.split("-");
-
- System.out.println(
- "Going to create brancheise folder:" + fileTokens[0] + " at " + this.remote_filePath);
- sftpChannel.cd(this.remote_filePath);
- try {
- sftpChannel.mkdir(fileTokens[0]);
- } catch (Exception ex) {
- System.out.println("Folder not created: " + ex.getMessage());
- }
- sftpChannel.cd(fileTokens[0]);
-
- sftpChannel.put(this.local_fileName, fileTokens[1]);
- System.out.println("File copied to remote server Successfully, archiving file");
-
- Movefile mv = new Movefile();
- mv.movefile(new File(this.local_fileName), this.archive_path);
- System.out.println("File archived to: " + this.archive_path);
- sftpChannel.disconnect();
- session.disconnect();
- System.out.println("Disconnect SFTP Channel");
- } catch (Exception ex) {
- ex.printStackTrace();
+ public SSHProtocol(
+ String user,
+ String password,
+ String host,
+ int port,
+ String local_fileName,
+ String remote_filePath,
+ String remote_fileName,
+ String archive_path) {
+ this.user = user;
+ this.password = password;
+ this.host = host;
+ this.port = port;
+ this.local_fileName = local_fileName;
+ this.remote_filePath = remote_filePath;
+ this.remote_fileName = remote_fileName;
+ this.archive_path = archive_path;
}
- }
- public void fetchFileSSH(String remote_report_pattern) {
- try {
- String local_folder_path_bkp = "/home/ec2-user/PRODFILES/reportFiles/processed_bkp";
- System.out.println("Going to FETCH files from remote Server");
- JSch jsch = new JSch();
- System.out.println(
- "Creating SSH Session: user@host:port |--->"
- + this.user
- + "@"
- + this.host
- + ":"
- + this.port);
- Session session = jsch.getSession(this.user, this.host, this.port);
- session.setPassword(this.password);
-
- Properties config = new Properties();
- config.put("StrictHostKeyChecking", "no");
- session.setConfig(config);
- System.out.println("Establishing Connection...");
- session.connect();
- System.out.println("Connection established.");
- System.out.println("Creating SFTP Channel.");
- ChannelSftp sftpChannel = (ChannelSftp) session.openChannel("sftp");
- sftpChannel.connect();
- System.out.println("SFTP Channel created.");
-
- sftpChannel.cd(this.remote_filePath);
- System.out.println(sftpChannel.pwd());
- String rootPath = sftpChannel.pwd();
- Vector list = sftpChannel.ls(sftpChannel.pwd());
-
- for (ChannelSftp.LsEntry entry : list) {
-
- System.out.println(
- "Current File/Folder: " + entry.getFilename() + " isDir" + entry.getAttrs().isDir());
- if (entry.getAttrs().isDir()) {
- if (entry.getFilename().equals(".") || entry.getFilename().equals("..")) {
- System.out.println("Skipping . and ..");
- continue;
- }
- System.out.println("Found folder: " + entry.getFilename());
-
- System.out.println("cd: " + rootPath + "/" + entry.getFilename());
- sftpChannel.cd(rootPath + "/" + entry.getFilename());
- System.out.println(sftpChannel.pwd());
- Vector subDirFileList = sftpChannel.ls(remote_report_pattern);
- for (ChannelSftp.LsEntry subDirFiles : subDirFileList) {
- if (!(new File(local_folder_path_bkp + "/" + subDirFiles.getFilename())).exists()) {
- sftpChannel.get(
- subDirFiles.getFilename(), this.local_fileName + subDirFiles.getFilename());
- System.out.println(
- "File: " + subDirFiles.getFilename() + " copied to :" + this.local_fileName);
-
- continue;
- }
+ public void sendFileSSH() {
+ try {
+ System.out.println("Going to SEND files from remote Server via SSH");
+ JSch jsch = new JSch();
System.out.println(
- "File: " + subDirFiles.getFilename() + " already present in local path");
- }
- }
- }
+ "Creating SSH Session: user@host:port |--->"
+ + this.user
+ + "@"
+ + this.host
+ + ":"
+ + this.port);
+ Session session = jsch.getSession(this.user, this.host, this.port);
+ session.setPassword(this.password);
- sftpChannel.disconnect();
- session.disconnect();
- System.out.println("Disconnect SFTP Channel");
- } catch (Exception e) {
- e.printStackTrace();
+ Properties config = new Properties();
+ config.put("StrictHostKeyChecking", "no");
+ session.setConfig(config);
+ System.out.println("Establishing Connection...");
+ session.connect();
+ System.out.println("Connection established.");
+ System.out.println("Creating SFTP Channel.");
+ ChannelSftp sftpChannel = (ChannelSftp) session.openChannel("sftp");
+ sftpChannel.connect();
+ System.out.println("SFTP Channel created.");
+ System.out.println(
+ "SFTP -- Local File Name: "
+ + this.local_fileName
+ + " Remote File Name: "
+ + this.remote_fileName);
+
+ String[] fileTokens = this.remote_fileName.split("-");
+
+ System.out.println(
+ "Going to create brancheise folder:" + fileTokens[0] + " at " + this.remote_filePath);
+ sftpChannel.cd(this.remote_filePath);
+ try {
+ sftpChannel.mkdir(fileTokens[0]);
+ } catch (Exception ex) {
+ System.out.println("Folder not created: " + ex.getMessage());
+ }
+ sftpChannel.cd(fileTokens[0]);
+
+ sftpChannel.put(this.local_fileName, fileTokens[1]);
+ System.out.println("File copied to remote server Successfully, archiving file");
+
+ Movefile mv = new Movefile();
+ mv.movefile(new File(this.local_fileName), this.archive_path);
+ System.out.println("File archived to: " + this.archive_path);
+ sftpChannel.disconnect();
+ session.disconnect();
+ System.out.println("Disconnect SFTP Channel");
+ } catch (Exception ex) {
+ ex.printStackTrace();
+ }
}
- }
-}
\ No newline at end of file
+
+ public void fetchFileSSH(String remote_report_pattern) {
+ try {
+ String local_folder_path_bkp = "/home/ec2-user/PRODFILES/reportFiles/processed_bkp";
+ System.out.println("Going to FETCH files from remote Server");
+ JSch jsch = new JSch();
+ System.out.println(
+ "Creating SSH Session: user@host:port |--->"
+ + this.user
+ + "@"
+ + this.host
+ + ":"
+ + this.port);
+ Session session = jsch.getSession(this.user, this.host, this.port);
+ session.setPassword(this.password);
+
+ Properties config = new Properties();
+ config.put("StrictHostKeyChecking", "no");
+ session.setConfig(config);
+ System.out.println("Establishing Connection...");
+ session.connect();
+ System.out.println("Connection established.");
+ System.out.println("Creating SFTP Channel.");
+ ChannelSftp sftpChannel = (ChannelSftp) session.openChannel("sftp");
+ sftpChannel.connect();
+ System.out.println("SFTP Channel created.");
+
+ sftpChannel.cd(this.remote_filePath);
+ System.out.println(sftpChannel.pwd());
+ String rootPath = sftpChannel.pwd();
+ Vector list = sftpChannel.ls(sftpChannel.pwd());
+
+ for (ChannelSftp.LsEntry entry : list) {
+
+ System.out.println(
+ "Current File/Folder: " + entry.getFilename() + " isDir" + entry.getAttrs().isDir());
+ if (entry.getAttrs().isDir()) {
+ if (entry.getFilename().equals(".") || entry.getFilename().equals("..")) {
+ System.out.println("Skipping . and ..");
+ continue;
+ }
+ System.out.println("Found folder: " + entry.getFilename());
+
+ System.out.println("cd: " + rootPath + "/" + entry.getFilename());
+ sftpChannel.cd(rootPath + "/" + entry.getFilename());
+ System.out.println(sftpChannel.pwd());
+ Vector subDirFileList = sftpChannel.ls(remote_report_pattern);
+ for (ChannelSftp.LsEntry subDirFiles : subDirFileList) {
+ if (!(new File(local_folder_path_bkp + "/" + subDirFiles.getFilename())).exists()) {
+ sftpChannel.get(
+ subDirFiles.getFilename(), this.local_fileName + subDirFiles.getFilename());
+ System.out.println(
+ "File: " + subDirFiles.getFilename() + " copied to :" + this.local_fileName);
+
+ continue;
+ }
+ System.out.println(
+ "File: " + subDirFiles.getFilename() + " already present in local path");
+ }
+ }
+ }
+
+ sftpChannel.disconnect();
+ session.disconnect();
+ System.out.println("Disconnect SFTP Channel");
+ } catch (Exception e) {
+ e.printStackTrace();
+ }
+ }
+}