Skip to content

B
business-java
Commit 2018d40f authored by dpawar's avatar dpawar
Browse files
Options

change sequence of veriables 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@95193 ce508802-f39f-4f6c-b175-0d175dae99d5
parent d07c1a00
Show whitespace changes
Inline Side-by-side
Showing with 217 additions and 92 deletions
webitm-fin/ibase/webitm/ejb/fin/InterCompReconcile.java
View file @ 2018d40f
...@@ -268,8 +268,12 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -268,8 +268,12 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
isError=true;
errString = e.getMessage(); errString = e.getMessage();
try {
conn.rollback();
} catch (Exception d) {
d.printStackTrace();
}
throw new ITMException(e); throw new ITMException(e);
} finally { } finally {
try { try {
...@@ -461,6 +465,11 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -461,6 +465,11 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
{ {
e.printStackTrace(); e.printStackTrace();
System.out.println("Exception ::"+ e.getMessage()); System.out.println("Exception ::"+ e.getMessage());
try {
conn.rollback();
} catch (Exception d) {
d.printStackTrace();
}
throw new ITMException(e); throw new ITMException(e);
} }
finally finally
...@@ -596,8 +605,8 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -596,8 +605,8 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
chgUser = genericUtility.getColumnValue("chg_user",dom); chgUser = genericUtility.getColumnValue("chg_user",dom);
chgTerm = genericUtility.getColumnValue("chg_term",dom); chgTerm = genericUtility.getColumnValue("chg_term",dom);
siteCodeFr = genericUtility.getColumnValue("site_code_to",dom); siteCodeFr = genericUtility.getColumnValue("site_code_fr",dom);
siteCodeTo = genericUtility.getColumnValue("site_code_fr",dom); siteCodeTo = genericUtility.getColumnValue("site_code_to",dom);
siteCodeFr = siteCodeFr == null? "" : siteCodeFr.trim(); siteCodeFr = siteCodeFr == null? "" : siteCodeFr.trim();
siteCodeTo = siteCodeTo == null? "" : siteCodeTo.trim(); siteCodeTo = siteCodeTo == null? "" : siteCodeTo.trim();
...@@ -638,9 +647,13 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -638,9 +647,13 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
private StringBuffer getXMLTransData(Connection conn, String sql, String insertSql, String objName, StringBuffer stringBuffer, String callBy,String reconcileType,String siteCodeFr,String siteCodeTo) throws Exception private StringBuffer getXMLTransData(Connection conn, String sql, String insertSql, String objName, StringBuffer stringBuffer, String callBy,String reconcileType,String siteCodeFr,String siteCodeTo) throws Exception
{ {
System.out.println("In getXMLTransData"); System.out.println("In getXMLTransData");
ConnDriver connDriver1 = new ConnDriver();
Connection conn1=null;
StringBuffer valueXmlString = new StringBuffer(""); StringBuffer valueXmlString = new StringBuffer("");
HashMap<String,Double> issueSiteMap=new HashMap<String,Double>(); HashMap<String,Double> issueSiteMap=new HashMap<String,Double>();
HashMap<String,Double> reseiverSiteMap=new HashMap<String,Double>(); HashMap<String,Double> reseiverSiteMap=new HashMap<String,Double>();
HashMap<String,String> issueSiteRefMap=new HashMap<String,String>();
HashMap<String,String> reseiverSiteRefMap=new HashMap<String,String>();
ArrayList<ArrayList> arrayListData = null; ArrayList<ArrayList> arrayListData = null;
ArrayList traceData = null; ArrayList traceData = null;
Document dom = null; Document dom = null;
...@@ -688,13 +701,14 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -688,13 +701,14 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
rs = null; rs = null;
} else if ("CallByManually".equalsIgnoreCase(callBy)) { } else if ("CallByManually".equalsIgnoreCase(callBy)) {
System.out.println("In CallByManually"); System.out.println("In CallByManually");
String refId = "",tranDate = "",gpNo = "",gpDate = "", amtStr = "",billNo = "",billDate = ""; String refSer = "",refId = "",tranDate = "",gpNo = "",gpDate = "", amtStr = "",billNo = "",billDate = "";
double dramt = 0,cramt = 0,tempAmt = 0,lamt = 0,ramt = 0; double dramt = 0,cramt = 0,tempAmt = 0,lamt = 0,ramt = 0;
if("Automatically".equalsIgnoreCase(reconcileType)){ if("Automatically".equalsIgnoreCase(reconcileType)){
System.out.println("In Automatically"); System.out.println("In Automatically");
rType ="A"; rType ="A";
while(rs.next()){ while(rs.next()){
if(siteCodeFr.equalsIgnoreCase(rs.getString("SITE_CODE"))) { if(siteCodeFr.equalsIgnoreCase(rs.getString("SITE_CODE"))) {
refSer = rs.getString("REF_SER");
refId = rs.getString("REF_ID"); refId = rs.getString("REF_ID");
tranDate = rs.getString("TRAN_DATE"); tranDate = rs.getString("TRAN_DATE");
gpNo = rs.getString("GP_NO"); gpNo = rs.getString("GP_NO");
...@@ -704,6 +718,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -704,6 +718,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
tempAmt = dramt + cramt; tempAmt = dramt + cramt;
System.out.println("refId["+refId+"],tranDate["+tranDate+"],gpNo["+gpNo+"],gpDate["+gpDate+"],dramt["+dramt+"],cramt["+cramt+"]"); System.out.println("refId["+refId+"],tranDate["+tranDate+"],gpNo["+gpNo+"],gpDate["+gpDate+"],dramt["+dramt+"],cramt["+cramt+"]");
refSer = refSer == null ? "" : refSer.trim();
refId = refId == null ? null : ("".equalsIgnoreCase(refId.trim()) ? null : refId); refId = refId == null ? null : ("".equalsIgnoreCase(refId.trim()) ? null : refId);
tranDate = tranDate == null ? null : ("".equalsIgnoreCase(tranDate.trim()) ? null : tranDate); tranDate = tranDate == null ? null : ("".equalsIgnoreCase(tranDate.trim()) ? null : tranDate);
gpNo = gpNo == null ? null : ("".equalsIgnoreCase(gpNo.trim()) ? null : gpNo); gpNo = gpNo == null ? null : ("".equalsIgnoreCase(gpNo.trim()) ? null : gpNo);
...@@ -716,6 +731,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -716,6 +731,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
lamt += tempAmt; lamt += tempAmt;
} else { } else {
issueSiteMap.put(siteCodeFr+":"+refId+":"+tranDate, tempAmt); issueSiteMap.put(siteCodeFr+":"+refId+":"+tranDate, tempAmt);
issueSiteRefMap.put(siteCodeFr+":"+refId+":"+tranDate, refSer);
lamt += tempAmt; lamt += tempAmt;
} }
...@@ -727,10 +743,12 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -727,10 +743,12 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
lamt += tempAmt; lamt += tempAmt;
} else { } else {
issueSiteMap.put(siteCodeFr+":"+gpNo+":"+gpDate, tempAmt); issueSiteMap.put(siteCodeFr+":"+gpNo+":"+gpDate, tempAmt);
issueSiteRefMap.put(siteCodeFr+":"+gpNo+":"+gpDate, refSer);
lamt += tempAmt; lamt += tempAmt;
} }
} }
} else if(siteCodeTo.equalsIgnoreCase(rs.getString("SITE_CODE"))) { } else if(siteCodeTo.equalsIgnoreCase(rs.getString("SITE_CODE"))) {
refSer = rs.getString("REF_SER");
refId = rs.getString("REF_ID"); refId = rs.getString("REF_ID");
tranDate = rs.getString("TRAN_DATE"); tranDate = rs.getString("TRAN_DATE");
billNo = rs.getString("BL_NO"); billNo = rs.getString("BL_NO");
...@@ -740,6 +758,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -740,6 +758,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
tempAmt = dramt + cramt; tempAmt = dramt + cramt;
System.out.println("refId["+refId+"],tranDate["+tranDate+"],BillNo["+billNo+"],BillDate["+billDate+"],dramt["+dramt+"],cramt["+cramt+"]"); System.out.println("refId["+refId+"],tranDate["+tranDate+"],BillNo["+billNo+"],BillDate["+billDate+"],dramt["+dramt+"],cramt["+cramt+"]");
refSer = refSer == null ? "" : refSer.trim();
refId = refId == null ? null : ("".equalsIgnoreCase(refId.trim()) ? null : refId); refId = refId == null ? null : ("".equalsIgnoreCase(refId.trim()) ? null : refId);
tranDate = tranDate == null ? null : ("".equalsIgnoreCase(tranDate.trim()) ? null : tranDate); tranDate = tranDate == null ? null : ("".equalsIgnoreCase(tranDate.trim()) ? null : tranDate);
billNo = billNo == null ? null : ("".equalsIgnoreCase(billNo.trim()) ? null : billNo); billNo = billNo == null ? null : ("".equalsIgnoreCase(billNo.trim()) ? null : billNo);
...@@ -752,16 +771,18 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -752,16 +771,18 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
ramt += tempAmt; ramt += tempAmt;
} else { } else {
reseiverSiteMap.put(siteCodeTo+":"+refId+":"+tranDate, tempAmt); reseiverSiteMap.put(siteCodeTo+":"+refId+":"+tranDate, tempAmt);
reseiverSiteRefMap.put(siteCodeTo+":"+refId+":"+tranDate, refSer);
ramt += tempAmt; ramt += tempAmt;
} }
} else if (billNo != null && billDate != null) { } else if (billNo != null && billDate != null) {
billNo = billNo.trim(); billNo = billNo.trim();
billDate = billDate.trim(); billDate = billDate.trim();
if(reseiverSiteMap.containsKey(siteCodeFr+":"+billNo+":"+billDate)) { if(reseiverSiteMap.containsKey(siteCodeTo+":"+billNo+":"+billDate)) {
reseiverSiteMap.put(siteCodeFr+":"+billNo+":"+billDate,reseiverSiteMap.get(siteCodeFr+":"+billNo+":"+billDate) + tempAmt); reseiverSiteMap.put(siteCodeTo+":"+billNo+":"+billDate,reseiverSiteMap.get(siteCodeTo+":"+billNo+":"+billDate) + tempAmt);
ramt += tempAmt; ramt += tempAmt;
} else { } else {
reseiverSiteMap.put(siteCodeFr+":"+billNo+":"+billDate, tempAmt); reseiverSiteMap.put(siteCodeTo+":"+billNo+":"+billDate, tempAmt);
reseiverSiteRefMap.put(siteCodeTo+":"+billNo+":"+billDate, refSer);
ramt += tempAmt; ramt += tempAmt;
} }
} }
...@@ -770,7 +791,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -770,7 +791,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
pstmt = null; pstmt = null;
rs = null; rs = null;
if(lamt == ramt) { if(lamt == ramt) {
arrayListData = buildTraceDataHM(issueSiteMap,reseiverSiteMap,siteCodeFr,siteCodeTo,rType); arrayListData = buildTraceDataHM(issueSiteMap,reseiverSiteMap,siteCodeFr,siteCodeTo,rType,issueSiteRefMap,reseiverSiteRefMap);
} }
} else if("Manually".equalsIgnoreCase(reconcileType)){ } else if("Manually".equalsIgnoreCase(reconcileType)){
System.out.println("In Manually"); System.out.println("In Manually");
...@@ -786,6 +807,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -786,6 +807,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
siteCode = siteCode == null ? "" : siteCode.trim(); siteCode = siteCode == null ? "" : siteCode.trim();
if(siteCodeFr.equalsIgnoreCase(siteCode)) { if(siteCodeFr.equalsIgnoreCase(siteCode)) {
refSer = eElement.getElementsByTagName("REF_SER").item(0).getTextContent();
refId = eElement.getElementsByTagName("REF_ID").item(0).getTextContent(); refId = eElement.getElementsByTagName("REF_ID").item(0).getTextContent();
tranDate = eElement.getElementsByTagName("TRAN_DATE").item(0).getTextContent(); tranDate = eElement.getElementsByTagName("TRAN_DATE").item(0).getTextContent();
gpNo = eElement.getElementsByTagName("GP_NO").item(0).getTextContent(); gpNo = eElement.getElementsByTagName("GP_NO").item(0).getTextContent();
...@@ -797,6 +819,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -797,6 +819,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
tempAmt = dramt + cramt; tempAmt = dramt + cramt;
System.out.println("refId["+refId+"],tranDate["+tranDate+"],gpNo["+gpNo+"],gpDate["+gpDate+"],dramt["+dramt+"],cramt["+cramt+"]"); System.out.println("refId["+refId+"],tranDate["+tranDate+"],gpNo["+gpNo+"],gpDate["+gpDate+"],dramt["+dramt+"],cramt["+cramt+"]");
refSer = refSer == null ? "" : refSer.trim();
refId = refId == null ? null : ("".equalsIgnoreCase(refId.trim()) ? null : refId); refId = refId == null ? null : ("".equalsIgnoreCase(refId.trim()) ? null : refId);
tranDate = tranDate == null ? null : ("".equalsIgnoreCase(tranDate.trim()) ? null : tranDate); tranDate = tranDate == null ? null : ("".equalsIgnoreCase(tranDate.trim()) ? null : tranDate);
gpNo = gpNo == null ? null : ("".equalsIgnoreCase(gpNo.trim()) ? null : gpNo); gpNo = gpNo == null ? null : ("".equalsIgnoreCase(gpNo.trim()) ? null : gpNo);
...@@ -809,6 +832,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -809,6 +832,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
lamt += tempAmt; lamt += tempAmt;
} else { } else {
issueSiteMap.put(siteCodeFr+":"+refId+":"+tranDate, tempAmt); issueSiteMap.put(siteCodeFr+":"+refId+":"+tranDate, tempAmt);
issueSiteRefMap.put(siteCodeFr+":"+refId+":"+tranDate, refSer);
lamt += tempAmt; lamt += tempAmt;
} }
...@@ -820,10 +844,12 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -820,10 +844,12 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
lamt += tempAmt; lamt += tempAmt;
} else { } else {
issueSiteMap.put(siteCodeFr+":"+gpNo+":"+gpDate, tempAmt); issueSiteMap.put(siteCodeFr+":"+gpNo+":"+gpDate, tempAmt);
issueSiteRefMap.put(siteCodeFr+":"+gpNo+":"+gpDate, refSer);
lamt += tempAmt; lamt += tempAmt;
} }
} }
} else if(siteCodeTo.equalsIgnoreCase(siteCode)) { } else if(siteCodeTo.equalsIgnoreCase(siteCode)) {
refSer = eElement.getElementsByTagName("REF_SER").item(0).getTextContent();
refId = eElement.getElementsByTagName("REF_ID").item(0).getTextContent(); refId = eElement.getElementsByTagName("REF_ID").item(0).getTextContent();
tranDate = eElement.getElementsByTagName("TRAN_DATE").item(0).getTextContent(); tranDate = eElement.getElementsByTagName("TRAN_DATE").item(0).getTextContent();
billNo = eElement.getElementsByTagName("BIL_NO").item(0).getTextContent(); billNo = eElement.getElementsByTagName("BIL_NO").item(0).getTextContent();
...@@ -835,6 +861,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -835,6 +861,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
tempAmt = dramt + cramt; tempAmt = dramt + cramt;
System.out.println("refId["+refId+"],tranDate["+tranDate+"],BillNo["+billNo+"],BillDate["+billDate+"],dramt["+dramt+"],cramt["+cramt+"]"); System.out.println("refId["+refId+"],tranDate["+tranDate+"],BillNo["+billNo+"],BillDate["+billDate+"],dramt["+dramt+"],cramt["+cramt+"]");
refSer = refSer == null ? "" : refSer.trim();
refId = refId == null ? null : ("".equalsIgnoreCase(refId.trim()) ? null : refId); refId = refId == null ? null : ("".equalsIgnoreCase(refId.trim()) ? null : refId);
tranDate = tranDate == null ? null : ("".equalsIgnoreCase(tranDate.trim()) ? null : tranDate); tranDate = tranDate == null ? null : ("".equalsIgnoreCase(tranDate.trim()) ? null : tranDate);
billNo = billNo == null ? null : ("".equalsIgnoreCase(billNo.trim()) ? null : billNo); billNo = billNo == null ? null : ("".equalsIgnoreCase(billNo.trim()) ? null : billNo);
...@@ -847,23 +874,25 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -847,23 +874,25 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
ramt += tempAmt; ramt += tempAmt;
} else { } else {
reseiverSiteMap.put(siteCodeTo+":"+refId+":"+tranDate, tempAmt); reseiverSiteMap.put(siteCodeTo+":"+refId+":"+tranDate, tempAmt);
reseiverSiteRefMap.put(siteCodeTo+":"+refId+":"+tranDate, refSer);
ramt += tempAmt; ramt += tempAmt;
} }
} else if (billNo != null && billDate != null) { } else if (billNo != null && billDate != null) {
billNo = billNo.trim(); billNo = billNo.trim();
billDate = billDate.trim(); billDate = billDate.trim();
if(reseiverSiteMap.containsKey(siteCodeFr+":"+billNo+":"+billDate)) { if(reseiverSiteMap.containsKey(siteCodeTo+":"+billNo+":"+billDate)) {
reseiverSiteMap.put(siteCodeFr+":"+billNo+":"+billDate,reseiverSiteMap.get(siteCodeFr+":"+billNo+":"+billDate) + tempAmt); reseiverSiteMap.put(siteCodeTo+":"+billNo+":"+billDate,reseiverSiteMap.get(siteCodeTo+":"+billNo+":"+billDate) + tempAmt);
ramt += tempAmt; ramt += tempAmt;
} else { } else {
reseiverSiteMap.put(siteCodeFr+":"+billNo+":"+billDate, tempAmt); reseiverSiteMap.put(siteCodeTo+":"+billNo+":"+billDate, tempAmt);
reseiverSiteRefMap.put(siteCodeTo+":"+billNo+":"+billDate, refSer);
ramt += tempAmt; ramt += tempAmt;
} }
} }
} }
} }
if(lamt == ramt) { if(lamt == ramt) {
arrayListData = buildTraceDataHM(issueSiteMap,reseiverSiteMap,siteCodeFr,siteCodeTo,rType); arrayListData = buildTraceDataHM(issueSiteMap,reseiverSiteMap,siteCodeFr,siteCodeTo,rType,issueSiteRefMap,reseiverSiteRefMap);
} }
} }
} }
...@@ -891,13 +920,17 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -891,13 +920,17 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
String [] uniqueKeyArr = getUniqueIntValue(uniqueKey); String [] uniqueKeyArr = getUniqueIntValue(uniqueKey);
int intS = Integer.parseInt(uniqueKeyArr[1]);*/ int intS = Integer.parseInt(uniqueKeyArr[1]);*/
System.out.println("@@@@@@@stringBuffer1["+stringBuffer+"]@@@@@@@,arrayListData.lenght["+arrayListData.size()+"]"); System.out.println("@@@@@@@stringBuffer1["+stringBuffer+"]@@@@@@@,arrayListData.lenght["+arrayListData.size()+"]");
System.out.println("arrayListData11---->["+arrayListData+"]");
pstmt = conn.prepareStatement(insertSql); pstmt = conn.prepareStatement(insertSql);
for (int itr = 0;itr < arrayListData.size();itr++) { for (int itr = 0;itr < arrayListData.size();itr++) {
traceData = arrayListData.get(itr); traceData = arrayListData.get(itr);
System.out.println("traceData1--"+itr+"--->>["+traceData+"]");
// String uniqueKey = String.valueOf(itr);
generator = new TransIDGenerator(stringBuffer.toString(),userId,CommonConstants.DB_NAME); generator = new TransIDGenerator(stringBuffer.toString(),userId,CommonConstants.DB_NAME);
String uniqueKey = generator.generateTranSeqID("INCORE", "tran_id", keyString, conn); String uniqueKey = generator.generateTranSeqID("INCORE", "tran_id", keyString, conn);
// System.out.println("uniqueKey-->>["+uniqueKey+"]");
//System.out.print("uniqueKeyERR:["+uniqueKeyArr[0].toString()+nf.format(intS)+"]"); //System.out.print("uniqueKeyERR:["+uniqueKeyArr[0].toString()+nf.format(intS)+"]");
System.out.println("ListData=1:["+uniqueKey+"]2:["+traceData.get(0)+"]3:["+traceData.get(1)+"]"+ System.out.println("ListData=1:["+uniqueKey+"]2:["+traceData.get(0)+"]3:["+traceData.get(1)+"]"+
...@@ -930,9 +963,21 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -930,9 +963,21 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
catch(SQLException e) { catch(SQLException e) {
System.out.println("SQL Exception In getXMLTransData method of InterCompReconcileProcess Class : "+e.getMessage()); System.out.println("SQL Exception In getXMLTransData method of InterCompReconcileProcess Class : "+e.getMessage());
e.printStackTrace(); e.printStackTrace();
try{
conn.rollback();
}
catch(Exception e1){
e1.printStackTrace();
}
} }
catch(Exception ex) { catch(Exception ex) {
System.out.println("Exception In getXMLTransData method of InterCompReconcileProcess Class : "+ex.getMessage()); System.out.println("Exception In getXMLTransData method of InterCompReconcileProcess Class : "+ex.getMessage());
try{
conn.rollback();
}
catch(Exception e1){
e1.printStackTrace();
}
ex.printStackTrace(); ex.printStackTrace();
} finally { } finally {
try{ try{
...@@ -944,6 +989,10 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -944,6 +989,10 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
rs.close(); rs.close();
rs = null; rs = null;
} }
if(conn1!=null){
conn1.close();
conn1=null;
}
}catch (SQLException se) { }catch (SQLException se) {
se.printStackTrace(); se.printStackTrace();
} }
...@@ -1028,6 +1077,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -1028,6 +1077,7 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
} catch(Exception e) { } catch(Exception e) {
System.out.println("SQL Exception In getXMLTransData method of InterCompReconcileProcess Class : "+e.getMessage()); System.out.println("SQL Exception In getXMLTransData method of InterCompReconcileProcess Class : "+e.getMessage());
e.printStackTrace(); e.printStackTrace();
} finally { } finally {
try{ try{
}catch (Exception se) { }catch (Exception se) {
...@@ -1036,17 +1086,18 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -1036,17 +1086,18 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
} }
return arrayListData; return arrayListData;
} }
private ArrayList<ArrayList> buildTraceDataHM(HashMap<String,Double> issueSiteMap,HashMap<String,Double> reseiverSiteMap,String siteCodeFr,String siteCodeTo,String rType) throws Exception private ArrayList<ArrayList> buildTraceDataHM(HashMap<String,Double> issueSiteMap,HashMap<String,Double> reseiverSiteMap,String siteCodeFr,String siteCodeTo,String rType,HashMap<String,String> issueSiteRefMap,HashMap<String,String> reseiverSiteRefMap) throws Exception
{ {
System.out.println("In buildTraceDataHM"); System.out.println("In buildTraceDataHM");
System.out.println("issueSiteMap:["+issueSiteMap+"],reseiverSiteMap:["+reseiverSiteMap+"]"); System.out.println("issueSiteMap:["+issueSiteMap+"],reseiverSiteMap:["+reseiverSiteMap+"]");
ArrayList<ArrayList> arrayListData = new ArrayList<ArrayList>(); ArrayList<ArrayList> arrayListData = new ArrayList<ArrayList>();
String key = "",invNo = "",invDate = ""; ArrayList<ArrayList> issuesList = null;
ArrayList<ArrayList> receiverList = null;
String key = "",firstRefSer = "",secondRefSer = "";
double firstSite = 0,secondSite = 0; double firstSite = 0,secondSite = 0;
int leftcnt = 0, rightcnt = 0;
try { try {
ArrayList traceData = null; ArrayList traceData = null;
String refId = "",refDate = "";
double refAmt = 0.0,tempAmt = 0.0,dramt = 0,cramt = 0;
if ( issueSiteMap != null && reseiverSiteMap != null && issueSiteMap.size() > 0 && reseiverSiteMap.size() > 0 ) if ( issueSiteMap != null && reseiverSiteMap != null && issueSiteMap.size() > 0 && reseiverSiteMap.size() > 0 )
{ {
if("A".equalsIgnoreCase(rType)) if("A".equalsIgnoreCase(rType))
...@@ -1065,94 +1116,126 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -1065,94 +1116,126 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
{ {
firstSite = issueSiteMap.get(key); firstSite = issueSiteMap.get(key);
secondSite = reseiverSiteMap.get(siteCodeTo+":"+keyArray[1].toString()+":"+keyArray[2].toString()); secondSite = reseiverSiteMap.get(siteCodeTo+":"+keyArray[1].toString()+":"+keyArray[2].toString());
firstRefSer = issueSiteRefMap.get(siteCodeTo+":"+keyArray[1].toString()+":"+keyArray[2].toString());
secondRefSer = reseiverSiteRefMap.get(siteCodeTo+":"+keyArray[1].toString()+":"+keyArray[2].toString());
if(firstSite == secondSite) if(firstSite == secondSite)
{ {
System.out.println("Ala re ala"); System.out.println("Ala re ala");
traceData = null;
traceData = new ArrayList<String>(); traceData = new ArrayList<String>();
java.util.Date date = new java.util.Date(keyArray[2].toString()); java.util.Date date = new java.util.Date(keyArray[2].toString());
Timestamp time = new Timestamp(date.getTime()); Timestamp time = new Timestamp(date.getTime());
traceData.add(time); traceData.add(time);
traceData.add(null); traceData.add(firstRefSer);
traceData.add(keyArray[1].toString()); traceData.add(keyArray[1].toString());
traceData.add(null); traceData.add(secondRefSer);
traceData.add(keyArray[1].toString()); traceData.add(keyArray[1].toString());
traceData.add(siteCodeFr); traceData.add(siteCodeFr);
traceData.add(siteCodeTo); traceData.add(siteCodeTo);
traceData.add(firstSite); traceData.add(firstSite);
arrayListData.add(traceData); arrayListData.add(traceData);
traceData.clear();
traceData = null;
} }
} }
} }
} }
else if("M".equalsIgnoreCase(rType)) else if("M".equalsIgnoreCase(rType))
{ {
Set<String> issueSet = issueSiteMap.keySet(); issuesList = getArrayListHM(issueSiteMap,issueSiteRefMap);
Iterator itr = issueSet.iterator(); receiverList = getArrayListHM(reseiverSiteMap,reseiverSiteRefMap);
while(itr.hasNext())
{
key = (String)itr.next();
System.out.println("key["+key+"]");
String[] keyArray = key.split(":");
System.out.println("1:["+keyArray[0]+"]");
System.out.println("2:["+keyArray[1]+"]");
System.out.println("3:["+keyArray[2]+"]");
System.out.println("Ala re ala");
firstSite = issueSiteMap.get(key);
firstSite = (Double)issuesList.get(0).get(3);
secondSite = (Double)receiverList.get(0).get(3);
while(true)
{
if(issuesList.size() == leftcnt && receiverList.size() == rightcnt)
{
break;
}
else if(firstSite == secondSite)
{
System.out.println("AAAAA:leftcnt["+leftcnt+"],rightcnt["+rightcnt+"],firstSite["+firstSite+"]");
traceData = null;
traceData = new ArrayList<String>(); traceData = new ArrayList<String>();
java.util.Date date = new java.util.Date(keyArray[2].toString()); java.util.Date date = new java.util.Date(issuesList.get(leftcnt).get(2).toString());
Timestamp time = new Timestamp(date.getTime()); Timestamp time = new Timestamp(date.getTime());
traceData.add(time); traceData.add(time);
traceData.add(null); traceData.add(issuesList.get(leftcnt).get(4).toString());
traceData.add(keyArray[1].toString()); traceData.add(issuesList.get(leftcnt).get(1).toString());
traceData.add(null); traceData.add(receiverList.get(rightcnt).get(4).toString());
traceData.add(keyArray[1].toString()); traceData.add(receiverList.get(rightcnt).get(1).toString());
traceData.add(siteCodeFr); traceData.add(issuesList.get(leftcnt).get(0).toString());
traceData.add(siteCodeTo); traceData.add(receiverList.get(rightcnt).get(0).toString());
traceData.add(firstSite); traceData.add(firstSite);
arrayListData.add(traceData); arrayListData.add(traceData);
traceData.clear();
traceData = null; leftcnt++;
rightcnt++;
if(leftcnt < issuesList.size() && rightcnt < receiverList.size()) {
firstSite = (Double)issuesList.get(leftcnt).get(3);
secondSite = (Double)receiverList.get(rightcnt).get(3);
} }
issueSet.clear(); }
issueSet = null; else if(firstSite > secondSite)
itr = null;
firstSite = 0;
issueSet = reseiverSiteMap.keySet();
itr = issueSet.iterator();
while(itr.hasNext())
{ {
key = (String)itr.next(); firstSite = firstSite - secondSite;
System.out.println("key["+key+"]"); System.out.println("BBBBB:leftcnt["+leftcnt+"],rightcnt["+rightcnt+"],secondSite["+secondSite+"]");
String[] keyArray = key.split(":"); traceData = null;
System.out.println("1:["+keyArray[0]+"]"); traceData = new ArrayList<String>();
System.out.println("2:["+keyArray[1]+"]"); java.util.Date date = new java.util.Date(issuesList.get(leftcnt).get(2).toString());
System.out.println("3:["+keyArray[2]+"]"); Timestamp time = new Timestamp(date.getTime());
System.out.println("Ala re ala"); traceData.add(time);
firstSite = reseiverSiteMap.get(key); traceData.add(issuesList.get(leftcnt).get(4).toString());
traceData.add(issuesList.get(leftcnt).get(1).toString());
traceData.add(receiverList.get(rightcnt).get(4).toString());
traceData.add(receiverList.get(rightcnt).get(1).toString());
traceData.add(issuesList.get(leftcnt).get(0).toString());
traceData.add(receiverList.get(rightcnt).get(0).toString());
traceData.add(secondSite);
arrayListData.add(traceData);
rightcnt++;
if(rightcnt < receiverList.size()) {
secondSite = (Double)receiverList.get(rightcnt).get(3);
}
}
else if(firstSite < secondSite)
{
secondSite = secondSite - firstSite;
System.out.println("CCCCC:leftcnt["+leftcnt+"],rightcnt["+rightcnt+"],firstSite["+firstSite+"]");
traceData = null;
traceData = new ArrayList<String>(); traceData = new ArrayList<String>();
java.util.Date date = new java.util.Date(keyArray[2].toString()); java.util.Date date = new java.util.Date(issuesList.get(leftcnt).get(2).toString());
Timestamp time = new Timestamp(date.getTime()); Timestamp time = new Timestamp(date.getTime());
traceData.add(time); traceData.add(time);
traceData.add(null); traceData.add(issuesList.get(leftcnt).get(4).toString());
traceData.add(keyArray[1].toString()); traceData.add(issuesList.get(leftcnt).get(1).toString());
traceData.add(null); traceData.add(receiverList.get(rightcnt).get(4).toString());
traceData.add(keyArray[1].toString()); traceData.add(receiverList.get(rightcnt).get(1).toString());
traceData.add(siteCodeFr); traceData.add(issuesList.get(leftcnt).get(0).toString());
traceData.add(siteCodeTo); traceData.add(receiverList.get(rightcnt).get(0).toString());
traceData.add(firstSite); traceData.add(firstSite);
arrayListData.add(traceData); arrayListData.add(traceData);
traceData.clear();
traceData = null; leftcnt++;
if(leftcnt < issuesList.size()) {
firstSite = (Double)issuesList.get(leftcnt).get(3);
}
}
} }
} }
issueSiteMap = null; issueSiteMap = null;
reseiverSiteMap = null; reseiverSiteMap = null;
siteCodeFr = null; siteCodeFr = null;
siteCodeTo = null; siteCodeTo = null;
traceData = null;
issuesList = null;
receiverList = null;
issueSiteRefMap = null;
reseiverSiteRefMap = null;
key = null;
firstRefSer = null;
secondRefSer = null;
} }
} catch(Exception e) { } catch(Exception e) {
System.out.println("SQL Exception In getXMLTransData method of InterCompReconcileProcess Class : "+e.getMessage()); System.out.println("SQL Exception In getXMLTransData method of InterCompReconcileProcess Class : "+e.getMessage());
...@@ -1194,6 +1277,48 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci ...@@ -1194,6 +1277,48 @@ public class InterCompReconcile extends ValidatorEJB implements InterCompReconci
return returnVal; return returnVal;
} }
private ArrayList<ArrayList> getArrayListHM(HashMap<String , Double> HMListAmount,HashMap<String , String> HMListRef)
{
ArrayList<ArrayList> resultList = new ArrayList<ArrayList>();
ArrayList tempList = null;
Set set = null;
Iterator itr = null;
String key = "",refSer = "";
double amount = 0.0;
try{
set = HMListAmount.keySet();
itr = set.iterator();
while(itr.hasNext())
{
key = (String)itr.next();
String[] keyArray = key.split(":");
System.out.println("1:["+keyArray[0]+"]");
System.out.println("2:["+keyArray[1]+"]");
System.out.println("3:["+keyArray[2]+"]");
amount = HMListAmount.get(key);
refSer = HMListRef.get(key);
tempList = null;
tempList = new ArrayList();
tempList.add(keyArray[0]);
tempList.add(keyArray[1]);
tempList.add(keyArray[2]);
tempList.add(amount);
tempList.add(refSer);
resultList.add(tempList);
}
tempList = null;
set = null;
itr = null;
key = null;
refSer = null;
}
catch(Exception e) {
e.printStackTrace();
}
return resultList;
}
protected String getColumnDescr(Connection conn, String columnName ,String tableName, String columnName2, String value) protected String getColumnDescr(Connection conn, String columnName ,String tableName, String columnName2, String value)
{ {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment