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

added Mughberia to Nabard bank list

Browse Source
This commit is contained in:
Md Asif
2025-08-05 12:32:02 +05:30
parent 7d256e38ff
commit b88fd9e0ae
1 changed files with 845 additions and 854 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -44,7 +44,7 @@ public class RequestResponse {
input1 = Scheduler.class.getClass().getResourceAsStream("/Properties.properties");
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");
} else {
apiURL = prop.getProperty("APIURL_UCB");
@@ -52,7 +52,7 @@ public class RequestResponse {
} catch (IOException ex) {
log.error(String.valueOf(ex.getMessage()) + " error in request response class line no 67");
} catch(Exception e) {
} catch (Exception e) {
log.error(e.getMessage());
e.printStackTrace();
} finally {
@@ -105,7 +105,8 @@ public class RequestResponse {
byte[] input = jsonInputString.getBytes("utf-8");
os.write(input, 0, input.length);
} finally {
if (os != null) os.close();
if (os != null)
os.close();
}
} finally {
exception2 = null;
@@ -396,8 +397,7 @@ public class RequestResponse {
connection = Util.getDBConnection();
statement = connection.createStatement();
rs =
statement.executeQuery(
rs = statement.executeQuery(
"select * from rupay_kcc_api_map where status='Y' and API_TYPE='TXN'");
while (rs.next()) {
url = rs.getString(8);
@@ -414,7 +414,8 @@ public class RequestResponse {
} finally {
try {
if (connection != null) connection.close();
if (connection != null)
connection.close();
} catch (SQLException e1) {
log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 382");
@@ -434,8 +435,7 @@ public class RequestResponse {
connection = Util.getDBConnection();
st = connection.createStatement();
query =
"insert into neft_rtgs_dbtl_api_error_log"
query = "insert into neft_rtgs_dbtl_api_error_log"
+ " (bank_code,proc_date,proc_time,api_type,error_msg,error_at) values('"
+ bankcode
+ "','"
@@ -455,7 +455,8 @@ public class RequestResponse {
} finally {
try {
if (connection != null) connection.close();
if (connection != null)
connection.close();
} catch (SQLException e1) {
log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 498 ");
@@ -474,8 +475,7 @@ public class RequestResponse {
connection = Util.getDBConnectionforAPI();
st = connection.createStatement();
query =
"insert into neft_rtgs_dbtl_api_error_log"
query = "insert into neft_rtgs_dbtl_api_error_log"
+ " (bank_code,proc_date,proc_time,api_type,error_msg,error_at) values('"
+ bankcode
+ "','"
@@ -495,7 +495,8 @@ public class RequestResponse {
} finally {
try {
if (connection != null) connection.close();
if (connection != null)
connection.close();
} catch (SQLException e1) {
log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 531 ");
@@ -516,16 +517,14 @@ public class RequestResponse {
connection = Util.getDBConnection();
st = connection.createStatement();
rs =
st.executeQuery(
rs = st.executeQuery(
"select l.bankcode,l.jrnl_id,l.tran_date from outward_neft_api_log l where"
+ " l.tran_date='"
+ date
+ "'");
while (rs.next()) {
String comb =
String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
String comb = String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
combination.add(comb);
}
@@ -553,8 +552,7 @@ public class RequestResponse {
continue;
}
query =
"insert into outward_neft_api_log(bankcode, jrnl_id, ref_no, tran_date,txn_amt,"
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 ('"
@@ -568,8 +566,7 @@ public class RequestResponse {
+ "',("
+ d.getTrnamt()
+ "),'";
query =
String.valueOf(query)
query = String.valueOf(query)
+ d.getRecvr_acct_no()
+ "','"
+ d.getSender_acc_no()
@@ -610,7 +607,8 @@ public class RequestResponse {
} finally {
try {
if (connection != null) connection.close();
if (connection != null)
connection.close();
} catch (SQLException e1) {
log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 466");
@@ -634,16 +632,14 @@ public class RequestResponse {
connection = Util.getDBConnectionforAPI();
st = connection.createStatement();
rs =
st.executeQuery(
rs = st.executeQuery(
"select l.bankcode,l.jrnl_id,l.tran_date from outward_neft_api_log l where"
+ " l.tran_date='"
+ date
+ "'");
while (rs.next()) {
String comb =
String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
String comb = String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
combination.add(comb);
}
@@ -666,8 +662,7 @@ public class RequestResponse {
continue;
}
query =
"insert into outward_neft_api_log(bankcode, jrnl_id, ref_no, tran_date,txn_amt,"
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 ('"
@@ -681,8 +676,7 @@ public class RequestResponse {
+ "',("
+ d.getTrnamt()
+ "),'";
query =
String.valueOf(query)
query = String.valueOf(query)
+ d.getRecvr_acct_no()
+ "','"
+ d.getSender_acc_no()
@@ -723,7 +717,8 @@ public class RequestResponse {
} finally {
try {
if (connection != null) connection.close();
if (connection != null)
connection.close();
} catch (SQLException e1) {
log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 617");
@@ -747,15 +742,13 @@ public class RequestResponse {
connection = Util.getDBConnection();
st = connection.createStatement();
rs =
st.executeQuery(
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);
String comb = String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
combination.add(comb);
}
@@ -778,8 +771,7 @@ public class RequestResponse {
continue;
}
query =
"insert into inward_neft_api_log (bankcode,jrnl_id, ref_no, txn_date, txn_amt,"
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 ('"
@@ -828,7 +820,8 @@ public class RequestResponse {
} finally {
try {
if (connection != null) connection.close();
if (connection != null)
connection.close();
} catch (SQLException e1) {
log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 775");
@@ -849,15 +842,13 @@ public class RequestResponse {
connection = Util.getDBConnectionforAPI();
st = connection.createStatement();
rs =
st.executeQuery(
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);
String comb = String.valueOf(rs.getString(1)) + "|" + rs.getString(2) + "|" + rs.getString(3);
combination1.add(comb);
}
@@ -886,8 +877,7 @@ public class RequestResponse {
continue;
}
query =
"insert into inward_neft_api_log (bankcode,jrnl_id, ref_no, txn_date, txn_amt,"
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 ('"
@@ -935,7 +925,8 @@ public class RequestResponse {
} finally {
try {
if (connection != null) connection.close();
if (connection != null)
connection.close();
} catch (SQLException e1) {
log.error(
String.valueOf(e1.getMessage()) + " error in request response class on line no 838");