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");
      }
    } catch (IOException ex) {

      log.error(String.valueOf(ex.getMessage()) + " error in request response class line no 67");
    } catch(Exception e) {
        logger.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());
          databean.setBenef_address(dataD.get("benef_address").toString().trim());
          databean.setMsg_type(dataD.get("msg_type").toString().trim());
          databean.setReciever_ifsc(dataD.get("reciever_ifsc").toString().trim());
          databean.setBenf_name(dataD.get("benf_name").toString().trim());
          databean.setBenf_acct_no(dataD.get("benf_acct_no").toString().trim());

          databean.setReject_code(dataD.get("reject_code").toString().trim());

          databean.setRemiteer_name(dataD.get("remiteer_name").toString().trim());
          databean.setRemiteer_acct(dataD.get("remiteer_acct").toString().trim());
          databean.setRemiteer_addrs(dataD.get("remiteer_addrs").toString().trim());
          databean.setRemitter_info(dataD.get("remitter_info").toString().trim());
          databean.setMsg_type(dataD.get("msg_type").toString().trim());
          databean.setCreditor_amt(dataD.get("creditor_amt").toString().trim());
          databean.setSender_ifsc(dataD.get("sender_ifsc").toString().trim());
          databean.setStatus(dataD.get("status").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.setTrnamt(dataD.get("trnamt").toString().trim());
          databean.setUtr(dataD.get("utr").toString().trim());
          databean.setJrnl(dataD.getString("jrnl").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 336");
    }

    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", "inwardrtgs");
        System.out.println(finUrl);
        finalUrl.add(finUrl);
      }

    } catch (Exception ex) {
      log.error(
          String.valueOf(ex.getMessage()) + " error in request response class on line no 371");
    } finally {

      try {
        if (connection != null) connection.close();
      } catch (SQLException e1) {
        log.error(
            String.valueOf(e1.getMessage()) + " error in request response class on line no 378");
      }
    }
    return finalUrl;
  }

  public static ArrayList<String> getRequestBodyForPreviousDay() {
    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", "inwardrtgs");
        System.out.println(finUrl);
        finalUrl.add(finUrl);
      }

    } catch (Exception ex) {
      log.error(
          String.valueOf(ex.getMessage()) + " error in request response class on line no 411");
    } finally {

      try {
        if (connection != null) connection.close();
      } catch (SQLException e1) {
        log.error(
            String.valueOf(e1.getMessage()) + " error in request response class on line no 418");
      }
    }
    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.txn_date from inward_rtgs_api_log l where"
                    + " l.txn_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 450");
      }

      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 inward_rtgs_api_log(bankcode,jrnl_id,ref_no, txn_date,  amount,"
                + " remmiter_name,remmiter_acct, remmiter_addrs, benf_name, benf_acct_no,"
                + " benf_addrs, sender_ifsc, reciever_ifsc,msg_typ, creditor_amt, remmiter_info,"
                + " reject_code, status) values ('"
                + d.getBankcode()
                + "','"
                + d.getJrnl()
                + "','"
                + d.getUtr()
                + "','"
                + d.getTrandate()
                + "',abs("
                + d.getTrnamt()
                + "),'";
        query =
            String.valueOf(query)
                + d.getRemiteer_name()
                + "','"
                + d.getRemiteer_acct()
                + "','"
                + d.getRemiteer_addrs()
                + "','"
                + d.getBenf_name()
                + "','"
                + d.getBenf_acct_no()
                + "','"
                + d.getBenef_address()
                + "','"
                + d.getSender_ifsc()
                + "','"
                + d.getReciever_ifsc()
                + "','"
                + d.getMsg_type()
                + "','"
                + d.getCreditor_amt()
                + "','"
                + d.getRemitter_info()
                + "','"
                + d.getReject_code()
                + "','"
                + d.getStatus()
                + "')";
        log.info("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 rtgs_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 443");
    } finally {

      try {
        if (connection != null) connection.close();
      } catch (SQLException e1) {
        log.error(
            String.valueOf(e1.getMessage()) + " error in request response class on line no 450");
      }
    }
  }

  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'),'InwardRtgs','"
              + error_msg
              + "','"
              + Error_at
              + "')";

      st = connection.createStatement();
      int updatecount = st.executeUpdate(query);

      try {
        CallableStatement cs = connection.prepareCall("{call rtgs_api_txn_post}");
        cs.execute();

        log.info("Posting Completed, Check log.");

      } catch (Exception e) {
        log.error(String.valueOf(e.getMessage()) + " error in pocedure call");
      }

    } catch (Exception e) {
      log.error(String.valueOf(e.getMessage()) + " error in request response class on line no 474");
    } finally {

      try {
        if (connection != null) connection.close();
      } catch (SQLException e1) {
        log.error(
            String.valueOf(e1.getMessage()) + " error in request response class on line no 481 ");
      }
    }
  }

  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 rtgs_api_txn_post}");
        cs.execute();

        log.info("Posting Completed, Check log.");

      } catch (Exception e) {
        log.error(String.valueOf(e.getMessage()) + " error in pocedure call");
      }

    } catch (Exception e) {
      log.error(String.valueOf(e.getMessage()) + " error in request response class on line no 508");
    } finally {

      try {
        if (connection != null) connection.close();
      } catch (SQLException e1) {
        log.error(
            String.valueOf(e1.getMessage()) + " error in request response class on line no 515 ");
      }
    }
  }

  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.txn_date from inward_rtgs_api_log l where"
                    + " l.txn_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 547");
      }

      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 inward_rtgs_api_log(bankcode,jrnl_id,ref_no, txn_date,  amount,"
                + " remmiter_name,remmiter_acct, remmiter_addrs, benf_name, benf_acct_no,"
                + " benf_addrs, sender_ifsc, reciever_ifsc,msg_typ, creditor_amt, remmiter_info,"
                + " reject_code, status) values ('"
                + d.getBankcode()
                + "','"
                + d.getJrnl()
                + "','"
                + d.getUtr()
                + "','"
                + d.getTrandate()
                + "',abs("
                + d.getTrnamt()
                + "),'";
        query =
            String.valueOf(query)
                + d.getRemiteer_name()
                + "','"
                + d.getRemiteer_acct()
                + "','"
                + d.getRemiteer_addrs()
                + "','"
                + d.getBenf_name()
                + "','"
                + d.getBenf_acct_no()
                + "','"
                + d.getBenef_address()
                + "','"
                + d.getSender_ifsc()
                + "','"
                + d.getReciever_ifsc()
                + "','"
                + d.getMsg_type()
                + "','"
                + d.getCreditor_amt()
                + "','"
                + d.getRemitter_info()
                + "','"
                + d.getReject_code()
                + "','"
                + d.getStatus()
                + "')";
        log.info("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 rtgs_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 596");
    } finally {

      try {
        if (connection != null) connection.close();
      } catch (SQLException e1) {
        log.error(
            String.valueOf(e1.getMessage()) + " error in request response class on line no 603");
      }
    }
  }
}