md.asif5/ach_uih_dbtl_interface
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

added purulia and Mughberia to Nabard bank list

Browse Source
This commit is contained in:
Md Asif
2025-08-05 12:26:35 +05:30
parent 6c4249b49b
commit cbaee03e06
1 changed files with 620 additions and 625 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
src/main/java/com/methods/RequestResponse.java
View File

@@ -45,7 +45,7 @@ public class RequestResponse {
input1 = Scheduler.class.getClass().getResourceAsStream("/Properties.properties"); input1 = Scheduler.class.getClass().getResourceAsStream("/Properties.properties");
prop.load(input1); prop.load(input1);
if(bc.equals("0005") || bc.equals("0021")) { if (bc.equals("0005") || bc.equals("0021") || bc.equals("0016") || bc.equals("0018")) {
apiURL = prop.getProperty("APIURL_NABARD"); apiURL = prop.getProperty("APIURL_NABARD");
} else { } else {
apiURL = prop.getProperty("APIURL_UCB"); apiURL = prop.getProperty("APIURL_UCB");
@@ -105,7 +105,8 @@ public class RequestResponse {
byte[] input = jsonInputString.getBytes("utf-8"); byte[] input = jsonInputString.getBytes("utf-8");
os.write(input, 0, input.length); os.write(input, 0, input.length);
} finally { } finally {
if (os != null) os.close(); if (os != null)
os.close();
} }
} finally { } finally {
exception2 = null; exception2 = null;
@@ -314,8 +315,7 @@ public class RequestResponse {
connection = Util.getDBConnection(); connection = Util.getDBConnection();
statement = connection.createStatement(); statement = connection.createStatement();
rs = rs = statement.executeQuery(
statement.executeQuery(
"select * from rupay_kcc_api_map where status='Y' and API_TYPE='TXN'"); "select * from rupay_kcc_api_map where status='Y' and API_TYPE='TXN'");
while (rs.next()) { while (rs.next()) {
url = rs.getString(8); url = rs.getString(8);
@@ -333,7 +333,8 @@ public class RequestResponse {
} finally { } finally {
try { try {
if (connection != null) connection.close(); if (connection != null)
connection.close();
} catch (SQLException e1) { } catch (SQLException e1) {
log.error( log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 374"); String.valueOf(e1.getMessage()) + " error in request response class on line no 374");
@@ -362,8 +363,7 @@ public class RequestResponse {
connection = Util.getDBConnection(); connection = Util.getDBConnection();
statement = connection.createStatement(); statement = connection.createStatement();
rs = rs = statement.executeQuery(
statement.executeQuery(
"select * from rupay_kcc_api_map where status='Y' and API_TYPE='TXN'"); "select * from rupay_kcc_api_map where status='Y' and API_TYPE='TXN'");
while (rs.next()) { while (rs.next()) {
url = rs.getString(8); url = rs.getString(8);
@@ -381,7 +381,8 @@ public class RequestResponse {
} finally { } finally {
try { try {
if (connection != null) connection.close(); if (connection != null)
connection.close();
} catch (SQLException e1) { } catch (SQLException e1) {
log.error( log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 383"); String.valueOf(e1.getMessage()) + " error in request response class on line no 383");
@@ -403,15 +404,13 @@ public class RequestResponse {
connection = Util.getDBConnection(); connection = Util.getDBConnection();
st = connection.createStatement(); st = connection.createStatement();
rs = rs = st.executeQuery(
st.executeQuery(
"select l.bankcode,l.jrnl_id,l.tran_date from ach_api_log l where l.tran_date='" "select l.bankcode,l.jrnl_id,l.tran_date from ach_api_log l where l.tran_date='"
+ date + date
+ "'"); + "'");
while (rs.next()) { while (rs.next()) {
String comb = String comb = String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
combination.add(comb); combination.add(comb);
} }
@@ -439,8 +438,7 @@ public class RequestResponse {
continue; continue;
} }
query = query = "insert into ach_api_log(narration,status,bankcode,jrnl_id, tran_date, cbs_acct,"
"insert into ach_api_log(narration,status,bankcode,jrnl_id, tran_date, cbs_acct,"
+ " tran_amt,TXNIND) values ('" + " tran_amt,TXNIND) values ('"
+ d.getNarration() + d.getNarration()
+ "','" + "','"
@@ -454,8 +452,7 @@ public class RequestResponse {
+ "','" + "','"
+ d.getAcctno() + d.getAcctno()
+ "',"; + "',";
query = query = String.valueOf(query)
String.valueOf(query)
+ "abs(" + "abs("
+ d.getTrnamt() + d.getTrnamt()
+ "),(case when to_number(" + "),(case when to_number("
@@ -478,7 +475,8 @@ public class RequestResponse {
} finally { } finally {
try { try {
if (connection != null) connection.close(); if (connection != null)
connection.close();
} catch (SQLException e1) { } catch (SQLException e1) {
log.error( log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 358"); String.valueOf(e1.getMessage()) + " error in request response class on line no 358");
@@ -497,8 +495,7 @@ public class RequestResponse {
connection = Util.getDBConnection(); connection = Util.getDBConnection();
st = connection.createStatement(); st = connection.createStatement();
query = query = "insert into neft_rtgs_dbtl_api_error_log"
"insert into neft_rtgs_dbtl_api_error_log"
+ " (bank_code,proc_date,proc_time,api_type,error_msg,error_at) values('" + " (bank_code,proc_date,proc_time,api_type,error_msg,error_at) values('"
+ bankcode + bankcode
+ "','" + "','"
@@ -529,7 +526,8 @@ public class RequestResponse {
} finally { } finally {
try { try {
if (connection != null) connection.close(); if (connection != null)
connection.close();
} catch (SQLException e1) { } catch (SQLException e1) {
log.error( log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 91 "); String.valueOf(e1.getMessage()) + " error in request response class on line no 91 ");
@@ -548,8 +546,7 @@ public class RequestResponse {
connection = Util.getDBConnectionforAPI(); connection = Util.getDBConnectionforAPI();
st = connection.createStatement(); st = connection.createStatement();
query = query = "insert into neft_rtgs_dbtl_api_error_log"
"insert into neft_rtgs_dbtl_api_error_log"
+ " (bank_code,proc_date,proc_time,api_type,error_msg,error_at) values('" + " (bank_code,proc_date,proc_time,api_type,error_msg,error_at) values('"
+ bankcode + bankcode
+ "','" + "','"
@@ -580,7 +577,8 @@ public class RequestResponse {
} finally { } finally {
try { try {
if (connection != null) connection.close(); if (connection != null)
connection.close();
} catch (SQLException e1) { } catch (SQLException e1) {
log.error( log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 527 "); String.valueOf(e1.getMessage()) + " error in request response class on line no 527 ");
@@ -601,15 +599,13 @@ public class RequestResponse {
connection = Util.getDBConnectionforAPI(); connection = Util.getDBConnectionforAPI();
st = connection.createStatement(); st = connection.createStatement();
rs = rs = st.executeQuery(
st.executeQuery(
"select l.bankcode,l.jrnl_id,l.tran_date from ach_api_log l where l.tran_date='" "select l.bankcode,l.jrnl_id,l.tran_date from ach_api_log l where l.tran_date='"
+ date + date
+ "'"); + "'");
while (rs.next()) { while (rs.next()) {
String comb = String comb = String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
combination1.add(comb); combination1.add(comb);
} }
@@ -637,8 +633,7 @@ public class RequestResponse {
continue; continue;
} }
query = query = "insert into ach_api_log(narration,status,bankcode,jrnl_id, tran_date, cbs_acct,"
"insert into ach_api_log(narration,status,bankcode,jrnl_id, tran_date, cbs_acct,"
+ " tran_amt,TXNIND) values ('" + " tran_amt,TXNIND) values ('"
+ d.getNarration() + d.getNarration()
+ "','" + "','"
@@ -652,8 +647,7 @@ public class RequestResponse {
+ "','" + "','"
+ d.getAcctno() + d.getAcctno()
+ "',"; + "',";
query = query = String.valueOf(query)
String.valueOf(query)
+ "abs(" + "abs("
+ d.getTrnamt() + d.getTrnamt()
+ "),(case when to_number(" + "),(case when to_number("
@@ -680,7 +674,8 @@ public class RequestResponse {
} finally { } finally {
try { try {
if (connection != null) connection.close(); if (connection != null)
connection.close();
} catch (SQLException e1) { } catch (SQLException e1) {
log.error( log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 601 "); String.valueOf(e1.getMessage()) + " error in request response class on line no 601 ");