From b88fd9e0ae0e43441372fbdb6a1b4ba02aa24343 Mon Sep 17 00:00:00 2001 From: asif Date: Tue, 5 Aug 2025 12:32:02 +0530 Subject: [PATCH] added Mughberia to Nabard bank list --- .../java/com/methods/RequestResponse.java | 1699 ++++++++--------- 1 file changed, 845 insertions(+), 854 deletions(-) diff --git a/src/main/java/com/methods/RequestResponse.java b/src/main/java/com/methods/RequestResponse.java index a46b82f..e923f87 100644 --- a/src/main/java/com/methods/RequestResponse.java +++ b/src/main/java/com/methods/RequestResponse.java @@ -27,919 +27,910 @@ 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()); + 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 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) { - log.error(e.getMessage()); - e.printStackTrace(); - } finally { - - if (input1 != null) { + public static ArrayList get_response(String jsonInputString, String date) + throws IOException { + int responseCode = -1; + String reverseTrandate = ""; + InputStream input1 = null; + String apiURL = null; try { - input1.close(); - } catch (IOException e) { - log.error(e.getMessage()); + String bc = new JSONObject(jsonInputString).getString("bankcode"); + input1 = Scheduler.class.getClass().getResourceAsStream("/Properties.properties"); + + prop.load(input1); + if (bc.equals("0005") || bc.equals("0021") || bc.equals("0016") || bc.equals("0018")) { + 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) { + 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"); + } } - } else { + log.info("Req MSG : " + jsonInputString); - log.error( - "Either no properties file found or error in properties file path in request response" - + " class"); - } + ArrayList data = new ArrayList<>(); + ArrayList returndata = 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(); + JSONObject dataD = new JSONObject(JSonData); + + if (!dataD.getString("reject_reason").toString().trim().equalsIgnoreCase("")) { + + System.out.println("yes"); + + DataBean databean = new DataBean(); + databean.setTrantype(dataD.get("trantype").toString().trim()); + databean.setBankcode(dataD.get("bankcode").toString().trim()); + databean.setUtr(dataD.get("utr").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.setJrnl(dataD.get("jrnl").toString().trim()); + databean.setTrnamt(dataD.get("trnamt").toString().trim()); + databean.setSender_ifsc(dataD.getString("sender_ifsc").toString().trim()); + databean.setReciever_ifsc(dataD.getString("reciever_ifsc").toString().trim()); + databean.setSender_acc_no(dataD.getString("sender_acc_no").toString().trim()); + databean.setRecvr_acct_no(dataD.getString("recvr_acct_no").toString().trim()); + databean.setReject_code(dataD.getString("reject_code").toString().trim()); + databean.setReject_reason(dataD.getString("reject_reason").toString().trim()); + databean.setMsg_type(dataD.getString("msg_type").toString().trim()); + databean.setSndr_rcvr_info(dataD.getString("sndr_rcvr_info").toString().trim()); + databean.setSender_name(dataD.getString("sender_name").toString().trim()); + databean.setReciever_name(dataD.getString("reciever_name").toString().trim()); + databean.setBeneficiary_address( + dataD.getString("beneficiary_address").toString().trim()); + + returndata.add(databean); + + } else { + + System.out.println("no"); + DataBean databean = new DataBean(); + databean.setTrantype(dataD.get("trantype").toString().trim()); + databean.setBankcode(dataD.get("bankcode").toString().trim()); + databean.setUtr(dataD.get("utr").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.setJrnl(dataD.get("jrnl").toString().trim()); + databean.setTrnamt(dataD.get("trnamt").toString().trim()); + databean.setSender_ifsc(dataD.getString("sender_ifsc").toString().trim()); + databean.setReciever_ifsc(dataD.getString("reciever_ifsc").toString().trim()); + databean.setSender_acc_no(dataD.getString("sender_acc_no").toString().trim()); + databean.setRecvr_acct_no(dataD.getString("recvr_acct_no").toString().trim()); + databean.setReject_code(dataD.getString("reject_code").toString().trim()); + databean.setReject_reason(dataD.getString("reject_reason").toString().trim()); + databean.setMsg_type(dataD.getString("msg_type").toString().trim()); + databean.setSndr_rcvr_info(dataD.getString("sndr_rcvr_info").toString().trim()); + databean.setSender_name(dataD.getString("sender_name").toString().trim()); + databean.setReciever_name(dataD.getString("reciever_name").toString().trim()); + databean.setBeneficiary_address( + dataD.getString("beneficiary_address").toString().trim()); + + data.add(databean); + } + } + + try { + setDatainAPIDatabase(data, reverseTrandate); + } catch (Exception e) { + + String bankcode = ""; + String 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"); + } + } + + if (returndata.isEmpty()) { + + log.info("NO Return Found"); + } else { + + try { + setReturnDatainAPIDatabase(returndata, 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 { + setReturnDatainDatabase(returndata, 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 340"); + } + + return data; } - log.info("Req MSG : " + jsonInputString); + public static ArrayList getRequestBody() { + Date date = new Date(); - ArrayList data = new ArrayList<>(); - ArrayList returndata = new ArrayList<>(); - URL url = null; + DateFormat sdf = new SimpleDateFormat("yyyyMMdd"); - try { - url = new URL(apiURL); - } catch (MalformedURLException e1) { + Calendar cal = Calendar.getInstance(); + String dateToday = sdf.format(cal.getTime()); - 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); + log.info("Date :" + dateToday); + String url = null; + String bankCode = null; + ArrayList finalUrl = new ArrayList<>(); try { - ErrorStoreInDaatabaseIPKS(bankcode, reason, errordate, "CEDGE"); - } catch (Exception e) { + connection = Util.getDBConnection(); - log.info("Unable to add error log into ipks database"); - } + 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", "outwardneft"); + finalUrl.add(finUrl); + } - 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(); - JSONObject dataD = new JSONObject(JSonData); - - if (!dataD.getString("reject_reason").toString().trim().equalsIgnoreCase("")) { - - System.out.println("yes"); - - DataBean databean = new DataBean(); - databean.setTrantype(dataD.get("trantype").toString().trim()); - databean.setBankcode(dataD.get("bankcode").toString().trim()); - databean.setUtr(dataD.get("utr").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.setJrnl(dataD.get("jrnl").toString().trim()); - databean.setTrnamt(dataD.get("trnamt").toString().trim()); - databean.setSender_ifsc(dataD.getString("sender_ifsc").toString().trim()); - databean.setReciever_ifsc(dataD.getString("reciever_ifsc").toString().trim()); - databean.setSender_acc_no(dataD.getString("sender_acc_no").toString().trim()); - databean.setRecvr_acct_no(dataD.getString("recvr_acct_no").toString().trim()); - databean.setReject_code(dataD.getString("reject_code").toString().trim()); - databean.setReject_reason(dataD.getString("reject_reason").toString().trim()); - databean.setMsg_type(dataD.getString("msg_type").toString().trim()); - databean.setSndr_rcvr_info(dataD.getString("sndr_rcvr_info").toString().trim()); - databean.setSender_name(dataD.getString("sender_name").toString().trim()); - databean.setReciever_name(dataD.getString("reciever_name").toString().trim()); - databean.setBeneficiary_address( - dataD.getString("beneficiary_address").toString().trim()); - - returndata.add(databean); - - } else { - - System.out.println("no"); - DataBean databean = new DataBean(); - databean.setTrantype(dataD.get("trantype").toString().trim()); - databean.setBankcode(dataD.get("bankcode").toString().trim()); - databean.setUtr(dataD.get("utr").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.setJrnl(dataD.get("jrnl").toString().trim()); - databean.setTrnamt(dataD.get("trnamt").toString().trim()); - databean.setSender_ifsc(dataD.getString("sender_ifsc").toString().trim()); - databean.setReciever_ifsc(dataD.getString("reciever_ifsc").toString().trim()); - databean.setSender_acc_no(dataD.getString("sender_acc_no").toString().trim()); - databean.setRecvr_acct_no(dataD.getString("recvr_acct_no").toString().trim()); - databean.setReject_code(dataD.getString("reject_code").toString().trim()); - databean.setReject_reason(dataD.getString("reject_reason").toString().trim()); - databean.setMsg_type(dataD.getString("msg_type").toString().trim()); - databean.setSndr_rcvr_info(dataD.getString("sndr_rcvr_info").toString().trim()); - databean.setSender_name(dataD.getString("sender_name").toString().trim()); - databean.setReciever_name(dataD.getString("reciever_name").toString().trim()); - databean.setBeneficiary_address( - dataD.getString("beneficiary_address").toString().trim()); - - data.add(databean); - } - } - - try { - setDatainAPIDatabase(data, reverseTrandate); - } catch (Exception e) { - - String bankcode = ""; - String 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"); - } - } - - if (returndata.isEmpty()) { - - log.info("NO Return Found"); - } else { - - try { - setReturnDatainAPIDatabase(returndata, reverseTrandate); - } catch (Exception e) { - - String bankcode = "", reason = e.getMessage(); - DateFormat dateFormat = new SimpleDateFormat("ddMMyyyy"); - String errordate = dateFormat.format(new Date()); + } catch (Exception ex) { + log.error( + String.valueOf(ex.getMessage()) + " error in request response class on line no 375"); + } finally { try { - ErrorStoreInDaatabaseAPI(bankcode, reason, errordate, "API"); - } catch (Exception e2) { - - log.info("Unable to add error log into API database"); + if (connection != null) + connection.close(); + } catch (SQLException e1) { + log.error( + String.valueOf(e1.getMessage()) + " error in request response class on line no 382"); } - } - try { - setReturnDatainDatabase(returndata, reverseTrandate); - } catch (Exception e) { + } + return finalUrl; + } - String bankcode = ""; - String reason = e.getMessage(); - DateFormat dateFormat = new SimpleDateFormat("ddMMyyyy"); - String errordate = dateFormat.format(new Date()); + 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'),'OutNeft','" + + error_msg + + "','" + + Error_at + + "')"; + + st = connection.createStatement(); + int i = st.executeUpdate(query); + + } catch (Exception e) { + log.error(String.valueOf(e.getMessage()) + " error in request response class on line no 491"); + } finally { try { - ErrorStoreInDaatabaseIPKS(bankcode, reason, errordate, "IPKS"); - } catch (Exception e1) { - - log.info("Unable to add error log into ipks database"); + if (connection != null) + connection.close(); + } catch (SQLException e1) { + log.error( + String.valueOf(e1.getMessage()) + " error in request response class on line no 498 "); } - } } - } - - } catch (Exception e3) { - - log.error( - String.valueOf(e3.getMessage()) + " error in request response class on line no 340"); } - return data; - } + public static void ErrorStoreInDaatabaseAPI( + String bankcode, String error_msg, String errordate, String Error_at) { + Connection connection = null; - public static ArrayList getRequestBody() { - Date date = new Date(); + Statement st = null; + String query = null; - DateFormat sdf = new SimpleDateFormat("yyyyMMdd"); + try { + connection = Util.getDBConnectionforAPI(); + st = connection.createStatement(); - Calendar cal = Calendar.getInstance(); - String dateToday = sdf.format(cal.getTime()); + 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 + + "')"; - log.info("Date :" + dateToday); + st = connection.createStatement(); + int i = st.executeUpdate(query); - String url = null; - String bankCode = null; - ArrayList finalUrl = new ArrayList<>(); - try { - connection = Util.getDBConnection(); + } catch (Exception e) { + log.error(String.valueOf(e.getMessage()) + " error in request response class on line no 524"); + } finally { - 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", "outwardneft"); - finalUrl.add(finUrl); - } - - } catch (Exception ex) { - log.error( - String.valueOf(ex.getMessage()) + " error in request response class on line no 375"); - } finally { - - try { - if (connection != null) connection.close(); - } catch (SQLException e1) { - log.error( - String.valueOf(e1.getMessage()) + " error in request response class on line no 382"); - } + try { + if (connection != null) + connection.close(); + } catch (SQLException e1) { + log.error( + String.valueOf(e1.getMessage()) + " error in request response class on line no 531 "); + } + } } - return finalUrl; - } - public static void ErrorStoreInDaatabaseIPKS( - String bankcode, String error_msg, String errordate, String Error_at) { - Connection connection = null; + public static void setDatainDatabase(ArrayList data, String date) { + Connection connection = null; + ResultSet rs = null; + Statement st = null; + String query = null; + PreparedStatement statement = null; + ArrayList combination = new ArrayList<>(); - Statement st = null; - String query = null; + try { + try { + connection = Util.getDBConnection(); + st = connection.createStatement(); - try { - connection = Util.getDBConnection(); - st = connection.createStatement(); + rs = st.executeQuery( + "select l.bankcode,l.jrnl_id,l.tran_date from outward_neft_api_log l where" + + " l.tran_date='" + + date + + "'"); - 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'),'OutNeft','" - + error_msg - + "','" - + Error_at - + "')"; + while (rs.next()) { + String comb = String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3); - st = connection.createStatement(); - int i = st.executeUpdate(query); + combination.add(comb); + } + } catch (Exception ex) { + log.error( + String.valueOf(ex.getMessage()) + " error in request response class on line no 412"); + } - } catch (Exception e) { - log.error(String.valueOf(e.getMessage()) + " error in request response class on line no 491"); - } finally { + Iterator iter = data.iterator(); + Statement st2 = connection.createStatement(); + while (iter.hasNext()) { + DataBean d = iter.next(); - try { - if (connection != null) connection.close(); - } catch (SQLException e1) { - log.error( - String.valueOf(e1.getMessage()) + " error in request response class on line no 498 "); - } + 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 outward_neft_api_log(bankcode, jrnl_id, ref_no, tran_date,txn_amt," + + " recvr_acct_no, sender_acct_no, reciever_ifsc, sender_ifsc, sender_name," + + " reciever_name, beneficiary_address, sender_to_reciver_info, msg_type," + + " reject_code, reject_reason) values ('" + + d.getBankcode() + + "','" + + d.getJrnl() + + "','" + + d.getUtr() + + "','" + + d.getTrandate() + + "',(" + + d.getTrnamt() + + "),'"; + query = String.valueOf(query) + + d.getRecvr_acct_no() + + "','" + + d.getSender_acc_no() + + "','" + + d.getReciever_ifsc() + + "','" + + d.getSender_ifsc() + + "','" + + d.getSender_name() + + "','" + + d.getReciever_name() + + "','" + + d.getBeneficiary_address() + + "','" + + d.getSndr_rcvr_info() + + "','" + + d.getMsg_type() + + "','" + + d.getReject_code() + + "','" + + d.getReject_reason() + + "')"; + 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"); + + log.info("Posting Completed, Check log."); + + } catch (Exception ex) { + log.error( + String.valueOf(ex.getMessage()) + " error in request response class on line no 459"); + } finally { + + try { + if (connection != null) + connection.close(); + } catch (SQLException e1) { + log.error( + String.valueOf(e1.getMessage()) + " error in request response class on line no 466"); + } + } } - } - public static void ErrorStoreInDaatabaseAPI( - String bankcode, String error_msg, String errordate, String Error_at) { - Connection connection = null; + public static void setDatainAPIDatabase(ArrayList data, String date) { + Connection connection = null; + ResultSet rs = null; + Statement st = null; + String query = null; + PreparedStatement statement = null; + ArrayList bankCode = new ArrayList<>(); + ArrayList jrnl_id = new ArrayList<>(); + ArrayList txnDt = new ArrayList<>(); + ArrayList combination = new ArrayList<>(); - Statement st = null; - String query = null; + try { + try { + connection = Util.getDBConnectionforAPI(); + st = connection.createStatement(); - try { - connection = Util.getDBConnectionforAPI(); - st = connection.createStatement(); + rs = st.executeQuery( + "select l.bankcode,l.jrnl_id,l.tran_date from outward_neft_api_log l where" + + " l.tran_date='" + + date + + "'"); - 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 - + "')"; + while (rs.next()) { + String comb = String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3); - st = connection.createStatement(); - int i = st.executeUpdate(query); + combination.add(comb); + } - } catch (Exception e) { - log.error(String.valueOf(e.getMessage()) + " error in request response class on line no 524"); - } finally { + } catch (Exception ex) { + log.error( + String.valueOf(ex.getMessage()) + " error in request response class on line no 563"); + } - try { - if (connection != null) connection.close(); - } catch (SQLException e1) { - log.error( - String.valueOf(e1.getMessage()) + " error in request response class on line no 531 "); - } + Iterator 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"); + + continue; + } + query = "insert into outward_neft_api_log(bankcode, jrnl_id, ref_no, tran_date,txn_amt," + + " recvr_acct_no, sender_acct_no, reciever_ifsc, sender_ifsc, sender_name," + + " reciever_name, beneficiary_address, sender_to_reciver_info, msg_type," + + " reject_code, reject_reason) values ('" + + d.getBankcode() + + "','" + + d.getJrnl() + + "','" + + d.getUtr() + + "','" + + d.getTrandate() + + "',(" + + d.getTrnamt() + + "),'"; + query = String.valueOf(query) + + d.getRecvr_acct_no() + + "','" + + d.getSender_acc_no() + + "','" + + d.getReciever_ifsc() + + "','" + + d.getSender_ifsc() + + "','" + + d.getSender_name() + + "','" + + d.getReciever_name() + + "','" + + d.getBeneficiary_address() + + "','" + + d.getSndr_rcvr_info() + + "','" + + d.getMsg_type() + + "','" + + d.getReject_code() + + "','" + + d.getReject_reason() + + "')"; + 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"); + + log.info("Posting Completed, Check log."); + + } catch (Exception ex) { + log.error( + String.valueOf(ex.getMessage()) + " error in request response class on line no 610"); + } finally { + + try { + if (connection != null) + connection.close(); + } catch (SQLException e1) { + log.error( + String.valueOf(e1.getMessage()) + " error in request response class on line no 617"); + } + } } - } - public static void setDatainDatabase(ArrayList data, String date) { - Connection connection = null; - ResultSet rs = null; - Statement st = null; - String query = null; - PreparedStatement statement = null; - ArrayList combination = new ArrayList<>(); + public static void setReturnDatainDatabase(ArrayList data, String date) { + Connection connection = null; + ResultSet rs = null; + Statement st = null; + String query = null; + PreparedStatement statement = null; + ArrayList bankCode = new ArrayList<>(); + ArrayList jrnl_id = new ArrayList<>(); + ArrayList txnDt = new ArrayList<>(); + ArrayList combination = new ArrayList<>(); - try { - try { - connection = Util.getDBConnection(); - st = connection.createStatement(); + try { + try { + connection = Util.getDBConnection(); + st = connection.createStatement(); - rs = - st.executeQuery( - "select l.bankcode,l.jrnl_id,l.tran_date from outward_neft_api_log l where" - + " l.tran_date='" - + date - + "'"); + rs = st.executeQuery( + "select l.bankcode,l.jrnl_id,l.txn_date from inward_neft_api_log l.txn_date='" + + date + + "'"); - while (rs.next()) { - String comb = - String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3); + while (rs.next()) { + String comb = String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3); - combination.add(comb); + combination.add(comb); + } + + } catch (Exception ex) { + log.error( + String.valueOf(ex.getMessage()) + " error in request response class on line no 743"); + } + + Iterator 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"); + + continue; + } + query = "insert into inward_neft_api_log (bankcode,jrnl_id, ref_no, txn_date, txn_amt," + + " sender_ifsc, reciever_ifsc, sender_acct_no, sender_acct_name, remitter_detail," + + " remitter_info, recvr_acct_no, recvr_acct_name, status, reject_code," + + " reject_reason,msg_type) values ('" + + d.getBankcode() + + "','" + + d.getJrnl() + + "','" + + d.getUtr() + + "','" + + d.getTrandate() + + "',(" + + d.getTrnamt() + + "),'" + + d.getReciever_ifsc() + + "','" + + d.getSender_ifsc() + + "','" + + d.getRecvr_acct_no() + + "','" + + d.getReciever_name() + + "','" + + d.getReciever_name() + + "','" + + d.getReciever_name() + + "','" + + d.getSender_acc_no() + + "','" + + d.getSender_name() + + "','PROCESSED','" + + d.getReject_code() + + "','" + + d.getReject_reason() + + "','N2R')"; + log.info("SQL Statement :" + query); + + st2.addBatch(query); + log.info("Added to DB Insert Batch"); + } + + st2.executeBatch(); + log.info("Insert to DB Completed"); + + } catch (Exception ex) { + log.error( + String.valueOf(ex.getMessage()) + " error in request response class on line no 768"); + } finally { + + try { + if (connection != null) + connection.close(); + } catch (SQLException e1) { + log.error( + String.valueOf(e1.getMessage()) + " error in request response class on line no 775"); + } } - } catch (Exception ex) { - log.error( - String.valueOf(ex.getMessage()) + " error in request response class on line no 412"); - } - - Iterator 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 outward_neft_api_log(bankcode, jrnl_id, ref_no, tran_date,txn_amt," - + " recvr_acct_no, sender_acct_no, reciever_ifsc, sender_ifsc, sender_name," - + " reciever_name, beneficiary_address, sender_to_reciver_info, msg_type," - + " reject_code, reject_reason) values ('" - + d.getBankcode() - + "','" - + d.getJrnl() - + "','" - + d.getUtr() - + "','" - + d.getTrandate() - + "',(" - + d.getTrnamt() - + "),'"; - query = - String.valueOf(query) - + d.getRecvr_acct_no() - + "','" - + d.getSender_acc_no() - + "','" - + d.getReciever_ifsc() - + "','" - + d.getSender_ifsc() - + "','" - + d.getSender_name() - + "','" - + d.getReciever_name() - + "','" - + d.getBeneficiary_address() - + "','" - + d.getSndr_rcvr_info() - + "','" - + d.getMsg_type() - + "','" - + d.getReject_code() - + "','" - + d.getReject_reason() - + "')"; - 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"); - - log.info("Posting Completed, Check log."); - - } catch (Exception ex) { - log.error( - String.valueOf(ex.getMessage()) + " error in request response class on line no 459"); - } finally { - - try { - if (connection != null) connection.close(); - } catch (SQLException e1) { - log.error( - String.valueOf(e1.getMessage()) + " error in request response class on line no 466"); - } } - } - public static void setDatainAPIDatabase(ArrayList data, String date) { - Connection connection = null; - ResultSet rs = null; - Statement st = null; - String query = null; - PreparedStatement statement = null; - ArrayList bankCode = new ArrayList<>(); - ArrayList jrnl_id = new ArrayList<>(); - ArrayList txnDt = new ArrayList<>(); - ArrayList combination = new ArrayList<>(); + public static void setReturnDatainAPIDatabase(ArrayList data, String date) { + Connection connection = null; + ResultSet rs = null; + Statement st = null; + String query = null; + PreparedStatement statement = null; + ArrayList combination1 = new ArrayList<>(); - try { - try { - connection = Util.getDBConnectionforAPI(); - st = connection.createStatement(); + try { + try { + connection = Util.getDBConnectionforAPI(); + st = connection.createStatement(); - rs = - st.executeQuery( - "select l.bankcode,l.jrnl_id,l.tran_date from outward_neft_api_log l where" - + " l.tran_date='" - + date - + "'"); + rs = st.executeQuery( + "select l.bankcode,l.jrnl_id,l.txn_date from inward_neft_api_log l.txn_date='" + + date + + "'"); - while (rs.next()) { - String comb = - String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3); + while (rs.next()) { + String comb = String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3); - combination.add(comb); + combination1.add(comb); + } + } catch (Exception ex) { + log.error( + String.valueOf(ex.getMessage()) + " error in request response class on line no 806"); + } + + Iterator 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_neft_api_log (bankcode,jrnl_id, ref_no, txn_date, txn_amt," + + " sender_ifsc, reciever_ifsc, sender_acct_no, sender_acct_name, remitter_detail," + + " remitter_info, recvr_acct_no, recvr_acct_name, status, reject_code," + + " reject_reason,msg_type) values ('" + + d.getBankcode() + + "','" + + d.getJrnl() + + "','" + + d.getUtr() + + "','" + + d.getTrandate() + + "',(" + + d.getTrnamt() + + "),'" + + d.getReciever_ifsc() + + "','" + + d.getSender_ifsc() + + "','" + + d.getRecvr_acct_no() + + "','" + + d.getReciever_name() + + "','" + + d.getReciever_name() + + "','" + + d.getReciever_name() + + "','" + + d.getSender_acc_no() + + "','" + + d.getSender_name() + + "','PROCESSED','" + + d.getReject_code() + + "','" + + d.getReject_reason() + + "','N2R')"; + + st2.addBatch(query); + log.info("Added to DB Insert Batch"); + } + + st2.executeBatch(); + log.info("Insert to DB Completed"); + + } catch (Exception ex) { + log.error( + String.valueOf(ex.getMessage()) + " error in request response class on line no 831"); + } finally { + + try { + if (connection != null) + connection.close(); + } catch (SQLException e1) { + log.error( + String.valueOf(e1.getMessage()) + " error in request response class on line no 838"); + } } - - } catch (Exception ex) { - log.error( - String.valueOf(ex.getMessage()) + " error in request response class on line no 563"); - } - - Iterator 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"); - - continue; - } - query = - "insert into outward_neft_api_log(bankcode, jrnl_id, ref_no, tran_date,txn_amt," - + " recvr_acct_no, sender_acct_no, reciever_ifsc, sender_ifsc, sender_name," - + " reciever_name, beneficiary_address, sender_to_reciver_info, msg_type," - + " reject_code, reject_reason) values ('" - + d.getBankcode() - + "','" - + d.getJrnl() - + "','" - + d.getUtr() - + "','" - + d.getTrandate() - + "',(" - + d.getTrnamt() - + "),'"; - query = - String.valueOf(query) - + d.getRecvr_acct_no() - + "','" - + d.getSender_acc_no() - + "','" - + d.getReciever_ifsc() - + "','" - + d.getSender_ifsc() - + "','" - + d.getSender_name() - + "','" - + d.getReciever_name() - + "','" - + d.getBeneficiary_address() - + "','" - + d.getSndr_rcvr_info() - + "','" - + d.getMsg_type() - + "','" - + d.getReject_code() - + "','" - + d.getReject_reason() - + "')"; - 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"); - - log.info("Posting Completed, Check log."); - - } catch (Exception ex) { - log.error( - String.valueOf(ex.getMessage()) + " error in request response class on line no 610"); - } finally { - - try { - if (connection != null) connection.close(); - } catch (SQLException e1) { - log.error( - String.valueOf(e1.getMessage()) + " error in request response class on line no 617"); - } } - } - - public static void setReturnDatainDatabase(ArrayList data, String date) { - Connection connection = null; - ResultSet rs = null; - Statement st = null; - String query = null; - PreparedStatement statement = null; - ArrayList bankCode = new ArrayList<>(); - ArrayList jrnl_id = new ArrayList<>(); - ArrayList txnDt = new ArrayList<>(); - ArrayList 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_neft_api_log 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 743"); - } - - Iterator 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"); - - continue; - } - query = - "insert into inward_neft_api_log (bankcode,jrnl_id, ref_no, txn_date, txn_amt," - + " sender_ifsc, reciever_ifsc, sender_acct_no, sender_acct_name, remitter_detail," - + " remitter_info, recvr_acct_no, recvr_acct_name, status, reject_code," - + " reject_reason,msg_type) values ('" - + d.getBankcode() - + "','" - + d.getJrnl() - + "','" - + d.getUtr() - + "','" - + d.getTrandate() - + "',(" - + d.getTrnamt() - + "),'" - + d.getReciever_ifsc() - + "','" - + d.getSender_ifsc() - + "','" - + d.getRecvr_acct_no() - + "','" - + d.getReciever_name() - + "','" - + d.getReciever_name() - + "','" - + d.getReciever_name() - + "','" - + d.getSender_acc_no() - + "','" - + d.getSender_name() - + "','PROCESSED','" - + d.getReject_code() - + "','" - + d.getReject_reason() - + "','N2R')"; - log.info("SQL Statement :" + query); - - st2.addBatch(query); - log.info("Added to DB Insert Batch"); - } - - st2.executeBatch(); - log.info("Insert to DB Completed"); - - } catch (Exception ex) { - log.error( - String.valueOf(ex.getMessage()) + " error in request response class on line no 768"); - } finally { - - try { - if (connection != null) connection.close(); - } catch (SQLException e1) { - log.error( - String.valueOf(e1.getMessage()) + " error in request response class on line no 775"); - } - } - } - - public static void setReturnDatainAPIDatabase(ArrayList data, String date) { - Connection connection = null; - ResultSet rs = null; - Statement st = null; - String query = null; - PreparedStatement statement = null; - ArrayList 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_neft_api_log 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 806"); - } - - Iterator 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_neft_api_log (bankcode,jrnl_id, ref_no, txn_date, txn_amt," - + " sender_ifsc, reciever_ifsc, sender_acct_no, sender_acct_name, remitter_detail," - + " remitter_info, recvr_acct_no, recvr_acct_name, status, reject_code," - + " reject_reason,msg_type) values ('" - + d.getBankcode() - + "','" - + d.getJrnl() - + "','" - + d.getUtr() - + "','" - + d.getTrandate() - + "',(" - + d.getTrnamt() - + "),'" - + d.getReciever_ifsc() - + "','" - + d.getSender_ifsc() - + "','" - + d.getRecvr_acct_no() - + "','" - + d.getReciever_name() - + "','" - + d.getReciever_name() - + "','" - + d.getReciever_name() - + "','" - + d.getSender_acc_no() - + "','" - + d.getSender_name() - + "','PROCESSED','" - + d.getReject_code() - + "','" - + d.getReject_reason() - + "','N2R')"; - - st2.addBatch(query); - log.info("Added to DB Insert Batch"); - } - - st2.executeBatch(); - log.info("Insert to DB Completed"); - - } catch (Exception ex) { - log.error( - String.valueOf(ex.getMessage()) + " error in request response class on line no 831"); - } finally { - - try { - if (connection != null) connection.close(); - } catch (SQLException e1) { - log.error( - String.valueOf(e1.getMessage()) + " error in request response class on line no 838"); - } - } - } }