Cleaned and formatted the project after decompilation

Also addded the two server APIs for UCB and NABARD

.gitignore

@@ -0,0 +1,2 @@
+dependency-reduced-pom.xml
+target/

pom.xml

@@ -0,0 +1,69 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <groupId>com.main</groupId>
+    <artifactId>AchUihDbtlInterface</artifactId>
+    <version>1.0</version>
+    <packaging>jar</packaging>
+    <properties>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <maven.compiler.source>1.8</maven.compiler.source>
+        <maven.compiler.target>1.8</maven.compiler.target>
+        <exec.mainClass>com.main.ResponseMain</exec.mainClass>
+    </properties>
+    
+    <dependencies>
+        <dependency>
+            <groupId>org.json</groupId>
+            <artifactId>json</artifactId>
+            <version>20180130</version>
+        </dependency>
+        <dependency>
+            <groupId>log4j</groupId>
+            <artifactId>log4j</artifactId>
+            <version>1.2.17</version>
+        </dependency>
+        <dependency>
+            <groupId>com.oracle.database.jdbc</groupId>
+            <artifactId>ojdbc8</artifactId>
+            <version>23.5.0.24.07</version>
+        </dependency>
+    </dependencies>
+    
+    <build>
+        <plugins>
+            <!-- not using Maven Compiler Plugin as it is not necessay -->
+            <!-- <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.11.0</version>
+                <configuration>
+                    <release>1.8</release>
+                </configuration>
+            </plugin> -->
+
+            <!-- Maven Shade plugin to build fat or uber jar -->
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-shade-plugin</artifactId>
+                <version>3.2.4</version>
+                <executions>
+                    <execution>
+                        <phase>package</phase>
+                        <goals>
+                            <goal>shade</goal>
+                        </goals>
+                        <configuration>
+                            <transformers>
+                                <transformer implementation="org.apache.maven.plugins.shade.resource.ManifestResourceTransformer">
+                                    <mainClass>com.main.ResponseMain</mainClass>
+                                </transformer>
+                            </transformers>
+                        </configuration>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+    
+</project>

src/main/java/com/bean/DataBean.java

@@ -0,0 +1,77 @@
+package com.bean;
+
+public class DataBean {
+  private String trantype;
+  private String trandate;
+  private String bankcode;
+  private String narration;
+
+  public String getTrantype() {
+    return this.trantype;
+  }
+
+  private String trnamt;
+  private String jrnl;
+  private String acctno;
+  private String remarks;
+
+  public void setTrantype(String trantype) {
+    this.trantype = trantype;
+  }
+
+  public String getTrandate() {
+    return this.trandate;
+  }
+
+  public void setTrandate(String trandate) {
+    this.trandate = trandate;
+  }
+
+  public String getBankcode() {
+    return this.bankcode;
+  }
+
+  public void setBankcode(String bankcode) {
+    this.bankcode = bankcode;
+  }
+
+  public String getNarration() {
+    return this.narration;
+  }
+
+  public void setNarration(String narration) {
+    this.narration = narration;
+  }
+
+  public String getTrnamt() {
+    return this.trnamt;
+  }
+
+  public void setTrnamt(String trnamt) {
+    this.trnamt = trnamt;
+  }
+
+  public String getJrnl() {
+    return this.jrnl;
+  }
+
+  public void setJrnl(String jrnl) {
+    this.jrnl = jrnl;
+  }
+
+  public String getAcctno() {
+    return this.acctno;
+  }
+
+  public void setAcctno(String acctno) {
+    this.acctno = acctno;
+  }
+
+  public String getRemarks() {
+    return this.remarks;
+  }
+
+  public void setRemarks(String remarks) {
+    this.remarks = remarks;
+  }
+}

src/main/java/com/main/ResponseMain.java

@@ -0,0 +1,13 @@
+package com.main;
+
+import java.util.concurrent.Executors;
+import java.util.concurrent.ScheduledExecutorService;
+import java.util.concurrent.TimeUnit;
+
+public class ResponseMain {
+  static ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
+
+  public static void main(String[] args) {
+    service.scheduleAtFixedRate(new Scheduler(), 0L, 30L, TimeUnit.MINUTES);
+  }
+}

src/main/java/com/main/Scheduler.java

@@ -0,0 +1,101 @@
+package com.main;
+
+import com.methods.RequestResponse;
+import java.io.IOException;
+import java.io.InputStream;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.Properties;
+import org.apache.log4j.Logger;
+
+public class Scheduler implements Runnable {
+  static Logger log = Logger.getLogger(Scheduler.class.getName());
+  public static Properties prop = new Properties();
+
+  public void run() {
+      log.info("Inside run");
+    InputStream input = null;
+    try {
+      input = Scheduler.class.getClass().getResourceAsStream("/Properties.properties");
+
+      prop.load(input);
+    } catch (IOException ex) {
+
+      log.error(ex.getMessage());
+    } finally {
+      if (input != null) {
+        try {
+          input.close();
+        } catch (IOException e) {
+          log.error(e.getMessage());
+        }
+
+      } else {
+
+        log.error(
+            "Either no properties file found or error in properties file path in Scheduler class");
+      }
+    }
+    Date date = new Date();
+
+    DateFormat sdf = new SimpleDateFormat("yyyyMMdd");
+    Calendar cal = Calendar.getInstance();
+    String dateToday = sdf.format(cal.getTime());
+
+    log.info("DBTL Scheduled Run Begins...." + new Date());
+    try {
+      ArrayList<String> requestBodyList = RequestResponse.getRequestBody();
+      for (int j = 0; j < requestBodyList.size(); j++) {
+
+        log.info("Iterating for Next Bank API");
+
+        try {
+          RequestResponse.get_response(requestBodyList.get(j), dateToday);
+        } catch (IOException e) {
+          log.error(String.valueOf(e.getMessage()) + " for " + (String) requestBodyList.get(j));
+        }
+      }
+    } catch (Exception e) {
+
+      log.error(String.valueOf(e.getMessage()) + " error in line no 78 scheduler class");
+    }
+
+    log.info("End of DBTL Scheduled Run For today");
+
+    log.info(
+        "DBTL Scheduled Run Begins for previous day...."
+            + new Date((new Date()).getTime() - 86400000L));
+
+    DateFormat sdf1 = new SimpleDateFormat("yyyyMMdd");
+
+    Calendar cal1 = Calendar.getInstance();
+    cal1.setTime(new Date());
+    cal1.add(6, -1);
+
+    String dateToPreviousday = sdf1.format(cal1.getTime());
+    ArrayList<String> requestBodyListforpreviousday =
+        RequestResponse.getRequestBodyForPreviousDay();
+    log.info("requ body size" + requestBodyListforpreviousday.size());
+
+    for (int i = 0; i < requestBodyListforpreviousday.size(); i++) {
+
+      log.info("Iterating for Next Bank API");
+
+      try {
+        RequestResponse.get_response(requestBodyListforpreviousday.get(i), dateToPreviousday);
+      } catch (IOException e) {
+        log.error(
+            String.valueOf(e.getMessage())
+                + " error for  "
+                + (String) requestBodyListforpreviousday.get(i)
+                + " and date"
+                + dateToPreviousday);
+      }
+    }
+
+    log.info("End of Scheduled Run for previous day");
+  }
+}

src/main/java/com/methods/RequestResponse.java

@@ -0,0 +1,691 @@
+package com.methods;
+
+import com.bean.DataBean;
+import com.main.Scheduler;
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStream;
+import java.io.InputStreamReader;
+import java.io.OutputStream;
+import java.net.HttpURLConnection;
+import java.net.MalformedURLException;
+import java.net.URL;
+import java.sql.CallableStatement;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.text.DateFormat;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.Iterator;
+import java.util.Properties;
+import org.apache.log4j.Logger;
+import org.json.JSONArray;
+import org.json.JSONObject;
+
+public class RequestResponse {
+  static Connection connection = null;
+  static ResultSet rs = null;
+  static Statement statement = null;
+  public static Properties prop = new Properties();
+  static Logger log = Logger.getLogger(Scheduler.class.getName());
+
+  public static ArrayList<DataBean> get_response(String jsonInputString, String date)
+      throws IOException {
+    int responseCode = -1;
+    String reverseTrandate = "";
+    InputStream input1 = null;
+    String apiURL = null;
+    try {
+	  String bc = new JSONObject(jsonInputString).getString("bankcode");
+      input1 = Scheduler.class.getClass().getResourceAsStream("/Properties.properties");
+
+      prop.load(input1);
+      if(bc.equals("0005") || bc.equals("0021")) {
+          apiURL = prop.getProperty("APIURL_NABARD");
+      } else {
+          apiURL = prop.getProperty("APIURL_UCB");
+      }
+      apiURL = prop.getProperty("APIURL");
+    } catch (IOException ex) {
+
+      log.error(String.valueOf(ex.getMessage()) + " error in request response class line no 67");
+    } catch(Exception e) {
+		log.error(e.getMessage());
+		e.printStackTrace();
+	} finally {
+
+      if (input1 != null) {
+        try {
+          input1.close();
+        } catch (IOException e) {
+          log.error(e.getMessage());
+        }
+
+      } else {
+
+        log.error(
+            "Either no properties file found or error in properties file path in request response"
+                + " class");
+      }
+    }
+
+    log.info("Req MSG : " + jsonInputString);
+
+    ArrayList<DataBean> data = new ArrayList<>();
+    URL url = null;
+
+    try {
+      url = new URL(apiURL);
+    } catch (MalformedURLException e1) {
+
+      log.error(String.valueOf(e1.getMessage()) + " error in request response class on line no 96");
+    }
+    HttpURLConnection con = null;
+    try {
+      con = (HttpURLConnection) url.openConnection();
+      con.setRequestMethod("POST");
+      con.setRequestProperty("Content-Type", "application/json; utf-8");
+      con.setRequestProperty("Accept", "application/json");
+      con.setDoOutput(true);
+
+    } catch (IOException e2) {
+
+      log.error(
+          String.valueOf(e2.getMessage()) + " error in request response class on line no 110");
+    }
+
+    Exception exception1 = null, exception2 = null;
+    try {
+      OutputStream os = con.getOutputStream();
+      try {
+        byte[] input = jsonInputString.getBytes("utf-8");
+        os.write(input, 0, input.length);
+      } finally {
+        if (os != null) os.close();
+      }
+    } finally {
+      exception2 = null;
+      if (exception1 == null) {
+        exception1 = exception2;
+      } else if (exception1 != exception2) {
+        exception1.addSuppressed(exception2);
+      }
+    }
+
+    log.info("Response Code : " + responseCode);
+
+    BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
+
+    StringBuffer response = new StringBuffer();
+    response.append("{\"result\":");
+    try {
+      String inputLine;
+      while ((inputLine = in.readLine()) != null) {
+        response.append(inputLine);
+      }
+    } catch (IOException e1) {
+
+      log.error(
+          String.valueOf(e1.getMessage()) + " error in request response class on line no 139");
+    }
+    try {
+      in.close();
+    } catch (IOException e1) {
+
+      log.error(
+          String.valueOf(e1.getMessage()) + " error in request response class on line no 145");
+    }
+
+    try {
+      response.append("}");
+
+      if (response.toString().contains("No data found")) {
+
+        JSONObject json = new JSONObject(response.toString());
+        JSONObject errorobj = new JSONObject(json.get("result").toString());
+
+        String bankcode = errorobj.getString("bankcode");
+        String reason = errorobj.getString("reason");
+        String errordategetfromjson = errorobj.getString("trandate");
+        SimpleDateFormat formatter1 = new SimpleDateFormat("yyyyMMdd");
+        Date date2 = formatter1.parse(errordategetfromjson);
+        DateFormat dateFormat = new SimpleDateFormat("ddMMyyyy");
+        String errordate = dateFormat.format(date2);
+
+        try {
+          ErrorStoreInDaatabaseIPKS(bankcode, reason, errordate, "CEDGE");
+        } catch (Exception e) {
+
+          log.info("Unable to add error log into ipks database");
+        }
+
+        try {
+          ErrorStoreInDaatabaseAPI(bankcode, reason, errordate, "CEDGE");
+        } catch (Exception e) {
+
+          log.info("Unable to add error log into API database");
+        }
+
+      } else if (response.toString().contains("Unable to fetch data")) {
+
+        JSONObject json = new JSONObject(response.toString());
+        JSONObject errorobj = new JSONObject(json.get("result").toString());
+
+        String bankcode = errorobj.getString("bankcode");
+        String reason = errorobj.getString("reason");
+        String errordategetfromjson = errorobj.getString("trandate");
+        SimpleDateFormat formatter1 = new SimpleDateFormat("yyyyMMdd");
+        Date date2 = formatter1.parse(errordategetfromjson);
+        DateFormat dateFormat = new SimpleDateFormat("ddMMyyyy");
+        String errordate = dateFormat.format(date2);
+
+        try {
+          ErrorStoreInDaatabaseIPKS(bankcode, reason, errordate, "CEDGE");
+        } catch (Exception e) {
+
+          log.info("Unable to add error log into ipks database");
+        }
+
+        try {
+          ErrorStoreInDaatabaseAPI(bankcode, reason, errordate, "CEDGE");
+        } catch (Exception e) {
+
+          log.info("Unable to add error log into API database");
+        }
+      } else if (response.toString().contains("SERVER UNAVAILABLE")) {
+
+        JSONObject json = new JSONObject(response.toString());
+        JSONObject errorobj = new JSONObject(json.get("result").toString());
+
+        String bankcode = errorobj.getString("bankcode");
+        String reason = errorobj.getString("reason");
+        String errordategetfromjson = errorobj.getString("trandate");
+        SimpleDateFormat formatter1 = new SimpleDateFormat("yyyyMMdd");
+        Date date2 = formatter1.parse(errordategetfromjson);
+        DateFormat dateFormat = new SimpleDateFormat("ddMMyyyy");
+        String errordate = dateFormat.format(date2);
+
+        try {
+          ErrorStoreInDaatabaseIPKS(bankcode, reason, errordate, "CEDGE");
+        } catch (Exception e) {
+
+          log.info("Unable to add error log into ipks database");
+        }
+
+        try {
+          ErrorStoreInDaatabaseAPI(bankcode, reason, errordate, "CEDGE");
+        } catch (Exception e) {
+
+          log.info("Unable to add error log into API database");
+        }
+      } else {
+
+        System.out.println(response.toString());
+        JSONObject json = new JSONObject(response.toString());
+        JSONArray dataArray = new JSONArray(json.get("result").toString());
+
+        for (int i = 0; i < dataArray.length(); i++) {
+          String JSonData = dataArray.get(i).toString();
+          DataBean databean = new DataBean();
+
+          JSONObject dataD = new JSONObject(JSonData);
+
+          databean.setBankcode(dataD.get("bankcode").toString().trim());
+
+          String Trandate = dataD.get("trandate").toString().trim();
+          SimpleDateFormat formatter1 = new SimpleDateFormat("yyyyMMdd");
+          Date date1 = formatter1.parse(Trandate);
+          DateFormat dateFormat = new SimpleDateFormat("ddMMyyyy");
+          reverseTrandate = dateFormat.format(date1);
+
+          databean.setTrandate(reverseTrandate);
+
+          databean.setNarration(dataD.get("narration").toString().trim());
+          databean.setTrnamt(dataD.get("trnamt").toString().trim());
+
+          databean.setJrnl(dataD.getString("jrnl").toString().trim());
+          databean.setAcctno(dataD.getString("acctno").toString().trim());
+          databean.setRemarks(dataD.getString("remarks").toString().trim());
+
+          data.add(databean);
+        }
+
+        try {
+          setDatainAPIDatabase(data, reverseTrandate);
+        } catch (Exception e) {
+
+          String bankcode = "", reason = e.getMessage();
+          DateFormat dateFormat = new SimpleDateFormat("ddMMyyyy");
+          String errordate = dateFormat.format(new Date());
+
+          try {
+            ErrorStoreInDaatabaseAPI(bankcode, reason, errordate, "API");
+          } catch (Exception e2) {
+
+            log.info("Unable to add error log into API database");
+          }
+        }
+
+        try {
+          setDatainDatabase(data, reverseTrandate);
+        } catch (Exception e) {
+
+          String bankcode = "";
+          String reason = e.getMessage();
+          DateFormat dateFormat = new SimpleDateFormat("ddMMyyyy");
+          String errordate = dateFormat.format(new Date());
+
+          try {
+            ErrorStoreInDaatabaseIPKS(bankcode, reason, errordate, "IPKS");
+          } catch (Exception e1) {
+
+            log.info("Unable to add error log into ipks database");
+          }
+        }
+      }
+
+    } catch (Exception e3) {
+
+      log.error(
+          String.valueOf(e3.getMessage()) + " error in request response class on line no 235");
+    }
+
+    return data;
+  }
+
+  public static ArrayList<String> getRequestBody() {
+    Date date = new Date();
+
+    DateFormat sdf = new SimpleDateFormat("yyyyMMdd");
+
+    Calendar cal = Calendar.getInstance();
+    String dateToday = sdf.format(cal.getTime());
+
+    log.info("Date :" + dateToday);
+
+    String url = null;
+    String bankCode = null;
+    ArrayList<String> finalUrl = new ArrayList<>();
+    try {
+      connection = Util.getDBConnection();
+
+      statement = connection.createStatement();
+      rs =
+          statement.executeQuery(
+              "select * from rupay_kcc_api_map where status='Y' and API_TYPE='TXN'");
+      while (rs.next()) {
+        url = rs.getString(8);
+        bankCode = rs.getString(6);
+        String finUrl = url.replaceAll("dt", dateToday);
+        finUrl = finUrl.replaceAll("bcode", bankCode);
+
+        finUrl = finUrl.replaceAll("tnty", "dbtl");
+        finalUrl.add(finUrl);
+      }
+
+    } catch (Exception ex) {
+      log.error(
+          String.valueOf(ex.getMessage()) + " error in request response class on line no 367");
+    } finally {
+
+      try {
+        if (connection != null) connection.close();
+      } catch (SQLException e1) {
+        log.error(
+            String.valueOf(e1.getMessage()) + " error in request response class on line no 374");
+      }
+    }
+    return finalUrl;
+  }
+
+  public static ArrayList<String> getRequestBodyForPreviousDay() {
+    Date date = new Date();
+
+    DateFormat sdf = new SimpleDateFormat("yyyyMMdd");
+
+    Calendar cal = Calendar.getInstance();
+    cal.setTime(new Date());
+    cal.add(6, -1);
+
+    String dateToPreviousday = sdf.format(cal.getTime());
+
+    log.info("Date :" + dateToPreviousday);
+
+    String url = null;
+    String bankCode = null;
+    ArrayList<String> finalUrl = new ArrayList<>();
+    try {
+      connection = Util.getDBConnection();
+
+      statement = connection.createStatement();
+      rs =
+          statement.executeQuery(
+              "select * from rupay_kcc_api_map where status='Y' and API_TYPE='TXN'");
+      while (rs.next()) {
+        url = rs.getString(8);
+        bankCode = rs.getString(6);
+        String finUrl = url.replaceAll("dt", dateToPreviousday);
+        finUrl = finUrl.replaceAll("bcode", bankCode);
+        finUrl = finUrl.replaceAll("tnty", "dbtl");
+        System.out.println(finUrl);
+        finalUrl.add(finUrl);
+      }
+
+    } catch (Exception ex) {
+      log.error(
+          String.valueOf(ex.getMessage()) + " error in request response class on line no 376");
+    } finally {
+
+      try {
+        if (connection != null) connection.close();
+      } catch (SQLException e1) {
+        log.error(
+            String.valueOf(e1.getMessage()) + " error in request response class on line no 383");
+      }
+    }
+    return finalUrl;
+  }
+
+  public static void setDatainDatabase(ArrayList<DataBean> data, String date) {
+    Connection connection = null;
+    ResultSet rs = null;
+    Statement st = null;
+    String query = null;
+    PreparedStatement statement = null;
+    ArrayList<String> combination = new ArrayList<>();
+
+    try {
+      try {
+        connection = Util.getDBConnection();
+        st = connection.createStatement();
+
+        rs =
+            st.executeQuery(
+                "select l.bankcode,l.jrnl_id,l.tran_date from ach_api_log l where l.tran_date='"
+                    + date
+                    + "'");
+
+        while (rs.next()) {
+          String comb =
+              String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
+
+          combination.add(comb);
+        }
+      } catch (Exception ex) {
+        log.error(
+            String.valueOf(ex.getMessage()) + " error in request response class on line no 402");
+      }
+
+      Iterator<DataBean> iter = data.iterator();
+      Statement st2 = connection.createStatement();
+      while (iter.hasNext()) {
+        DataBean d = iter.next();
+
+        if (combination.contains(
+                String.valueOf(d.getBankcode()) + "|" + d.getJrnl() + "|" + d.getTrandate())
+            || d.getJrnl() == null
+            || d.getJrnl().equalsIgnoreCase("")) {
+          log.info(
+              "RECORD ALREADY PRESENT IPKS for "
+                  + d.getBankcode()
+                  + "|"
+                  + d.getJrnl()
+                  + "|"
+                  + d.getTrandate());
+
+          continue;
+        }
+        query =
+            "insert into ach_api_log(narration,status,bankcode,jrnl_id, tran_date, cbs_acct,"
+                + " tran_amt,TXNIND) values ('"
+                + d.getNarration()
+                + "','"
+                + d.getRemarks()
+                + "','"
+                + d.getBankcode()
+                + "','"
+                + d.getJrnl()
+                + "','"
+                + d.getTrandate()
+                + "','"
+                + d.getAcctno()
+                + "',";
+        query =
+            String.valueOf(query)
+                + "abs("
+                + d.getTrnamt()
+                + "),(case when to_number("
+                + d.getTrnamt()
+                + ") < 0 then 'DR' else 'CR' end))";
+        log.info("SQL Statement :" + query);
+        System.out.println(query);
+
+        st2.addBatch(query);
+        log.info("Added to DB Insert Batch");
+      }
+
+      st2.executeBatch();
+      log.info("Insert to DB Completed");
+      log.info("Posting Txns in IPKS");
+
+    } catch (Exception ex) {
+      log.error(
+          String.valueOf(ex.getMessage()) + " error in request response class on line no 451");
+    } finally {
+
+      try {
+        if (connection != null) connection.close();
+      } catch (SQLException e1) {
+        log.error(
+            String.valueOf(e1.getMessage()) + " error in request response class on line no 358");
+      }
+    }
+  }
+
+  public static void ErrorStoreInDaatabaseIPKS(
+      String bankcode, String error_msg, String errordate, String Error_at) {
+    Connection connection = null;
+
+    Statement st = null;
+    String query = null;
+
+    try {
+      connection = Util.getDBConnection();
+      st = connection.createStatement();
+
+      query =
+          "insert into neft_rtgs_dbtl_api_error_log"
+              + " (bank_code,proc_date,proc_time,api_type,error_msg,error_at) values('"
+              + bankcode
+              + "','"
+              + errordate
+              + "',to_date(to_char(SYSTIMESTAMP,"
+              + " 'DD-MON-RRHH24:MI:SS'),'DD-MON-RRHH24:MI:SS'),'Dbtl','"
+              + error_msg
+              + "','"
+              + Error_at
+              + "')";
+
+      st = connection.createStatement();
+      int updatecount = st.executeUpdate(query);
+
+      try {
+        CallableStatement cs = connection.prepareCall("{call ach_api_txn_post}");
+        cs.execute();
+
+        log.info("Posting Completed, Check log.");
+
+      } catch (Exception e) {
+
+        log.error(String.valueOf(e.getMessage()) + " error in procedure");
+      }
+
+    } catch (Exception e) {
+      log.error(String.valueOf(e.getMessage()) + " error in request response class on line no 484");
+    } finally {
+
+      try {
+        if (connection != null) connection.close();
+      } catch (SQLException e1) {
+        log.error(
+            String.valueOf(e1.getMessage()) + " error in request response class on line no 91 ");
+      }
+    }
+  }
+
+  public static void ErrorStoreInDaatabaseAPI(
+      String bankcode, String error_msg, String errordate, String Error_at) {
+    Connection connection = null;
+
+    Statement st = null;
+    String query = null;
+
+    try {
+      connection = Util.getDBConnectionforAPI();
+      st = connection.createStatement();
+
+      query =
+          "insert into neft_rtgs_dbtl_api_error_log"
+              + " (bank_code,proc_date,proc_time,api_type,error_msg,error_at) values('"
+              + bankcode
+              + "','"
+              + errordate
+              + "',to_date(to_char(SYSTIMESTAMP,"
+              + " 'DD-MON-RRHH24:MI:SS'),'DD-MON-RRHH24:MI:SS'),'Dbtl','"
+              + error_msg
+              + "','"
+              + Error_at
+              + "')";
+
+      st = connection.createStatement();
+      int updatecount = st.executeUpdate(query);
+
+      try {
+        CallableStatement cs = connection.prepareCall("{call ach_api_txn_post}");
+        cs.execute();
+
+        log.info("Posting Completed, Check log.");
+
+      } catch (Exception e) {
+
+        log.error(String.valueOf(e.getMessage()) + " error in procedure");
+      }
+
+    } catch (Exception e) {
+      log.error(String.valueOf(e.getMessage()) + " error in request response class on line no 519");
+    } finally {
+
+      try {
+        if (connection != null) connection.close();
+      } catch (SQLException e1) {
+        log.error(
+            String.valueOf(e1.getMessage()) + " error in request response class on line no 527 ");
+      }
+    }
+  }
+
+  public static void setDatainAPIDatabase(ArrayList<DataBean> data, String date) {
+    Connection connection = null;
+    ResultSet rs = null;
+    Statement st = null;
+    String query = null;
+    PreparedStatement statement = null;
+    ArrayList<String> combination1 = new ArrayList<>();
+
+    try {
+      try {
+        connection = Util.getDBConnectionforAPI();
+        st = connection.createStatement();
+
+        rs =
+            st.executeQuery(
+                "select l.bankcode,l.jrnl_id,l.tran_date from ach_api_log l where l.tran_date='"
+                    + date
+                    + "'");
+
+        while (rs.next()) {
+          String comb =
+              String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
+
+          combination1.add(comb);
+        }
+      } catch (Exception ex) {
+        log.error(
+            String.valueOf(ex.getMessage()) + " error in request response class on line no 559");
+      }
+
+      Iterator<DataBean> iter = data.iterator();
+      Statement st2 = connection.createStatement();
+      while (iter.hasNext()) {
+        DataBean d = iter.next();
+
+        if (combination1.contains(
+                String.valueOf(d.getBankcode()) + "|" + d.getJrnl() + "|" + d.getTrandate())
+            || d.getJrnl() == null
+            || d.getJrnl().equalsIgnoreCase("")) {
+          log.info(
+              "RECORD ALREADY PRESENT API for "
+                  + d.getBankcode()
+                  + "|"
+                  + d.getJrnl()
+                  + "|"
+                  + d.getTrandate());
+
+          continue;
+        }
+        query =
+            "insert into ach_api_log(narration,status,bankcode,jrnl_id, tran_date, cbs_acct,"
+                + " tran_amt,TXNIND) values ('"
+                + d.getNarration()
+                + "','"
+                + d.getRemarks()
+                + "','"
+                + d.getBankcode()
+                + "','"
+                + d.getJrnl()
+                + "','"
+                + d.getTrandate()
+                + "','"
+                + d.getAcctno()
+                + "',";
+        query =
+            String.valueOf(query)
+                + "abs("
+                + d.getTrnamt()
+                + "),(case when to_number("
+                + d.getTrnamt()
+                + ") < 0 then 'DR' else 'CR' end))";
+        log.info("SQL Statement :" + query);
+        System.out.println("SQL Statement :" + query);
+        st2.addBatch(query);
+        log.info("Added to DB Insert Batch");
+      }
+
+      st2.executeBatch();
+      log.info("Insert to DB Completed");
+      log.info("Posting Txns in IPKS");
+
+      CallableStatement cs = connection.prepareCall("{call ach_api_txn_post}");
+      cs.execute();
+
+      log.info("Posting Completed, Check log.");
+
+    } catch (Exception ex) {
+      log.error(
+          String.valueOf(ex.getMessage()) + " error in request response class on line no 594");
+    } finally {
+
+      try {
+        if (connection != null) connection.close();
+      } catch (SQLException e1) {
+        log.error(
+            String.valueOf(e1.getMessage()) + " error in request response class on line no 601 ");
+      }
+    }
+  }
+}

src/main/java/com/methods/Util.java

@@ -0,0 +1,44 @@
+package com.methods;
+
+import com.main.Scheduler;
+import java.sql.Connection;
+import java.sql.DriverManager;
+import org.apache.log4j.Logger;
+
+public class Util {
+  static Logger log = Logger.getLogger(Scheduler.class.getName());
+
+  public static Connection getDBConnection() {
+    Connection dbConnection = null;
+
+    try {
+      Class.forName(Scheduler.prop.getProperty("DB_DRIVER"));
+      dbConnection =
+          DriverManager.getConnection(
+              Scheduler.prop.getProperty("DB_URL"),
+              Scheduler.prop.getProperty("DB_USER"),
+              Scheduler.prop.getProperty("DB_PWD"));
+    } catch (Exception e) {
+      log.error(
+          String.valueOf(e.getMessage()) + " in Util class db connection error for IPKS database");
+    }
+    return dbConnection;
+  }
+
+  public static Connection getDBConnectionforAPI() {
+    Connection dbConnection = null;
+
+    try {
+      Class.forName(Scheduler.prop.getProperty("DB_DRIVER"));
+      dbConnection =
+          DriverManager.getConnection(
+              Scheduler.prop.getProperty("DB_URL_API"),
+              Scheduler.prop.getProperty("DB_USER_API"),
+              Scheduler.prop.getProperty("DB_PWD_API"));
+    } catch (Exception e) {
+      log.error(
+          String.valueOf(e.getMessage()) + " in Util class db connection error for API database");
+    }
+    return dbConnection;
+  }
+}

src/main/resources/Properties.properties

@@ -0,0 +1,15 @@
+DB_DRIVER=oracle.jdbc.OracleDriver
+
+# IPKS database credentials
+DB_URL=jdbc:oracle:thin:@ipksprod3.c7q7defafeea.ap-south-1.rds.amazonaws.com:1521:ipks
+DB_USER=pacs_db
+DB_PWD=pacs_db
+
+# IPKS API service database credentials
+DB_URL_API=jdbc:oracle:thin:@ipksapi.c7q7defafeea.ap-south-1.rds.amazonaws.com:1521:ipksapi
+DB_USER_API=api_db
+DB_PWD_API=api_db
+
+# New C-Edge APIs for UCB and NABARD banks
+APIURL_UCB=https://UCBIPKS.cedgeapiservices.in/IPKSTRAN
+APIURL_NABARD=https://NABARDIPKS.cedgeapiservices.in/IPKSTRAN

src/main/resources/log4j.properties

@@ -0,0 +1,9 @@
+# Define the root logger with appender file
+#log =G:/PALTU BANERJEE/workspace/DbtlInterface
+log=/home/ec2-user/NEFT_RTGS_DBT_LOGS/DBTL
+log4j.rootLogger=DEBUG, RollingAppender
+log4j.appender.RollingAppender=org.apache.log4j.DailyRollingFileAppender
+log4j.appender.RollingAppender.File=${log}/dbtl.out
+log4j.appender.RollingAppender.DatePattern='.'yyyy-MM-dd
+log4j.appender.RollingAppender.layout=org.apache.log4j.PatternLayout
+log4j.appender.RollingAppender.layout.ConversionPattern=[%p] %d %c %M - %m%n