Skip to content

B
business-java
Commit 975ce056 authored by kshinde's avatar kshinde
Browse files
Options

SordBulk bug fix [D17AKOY001] 

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@173559 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 95cca1f1
Hide whitespace changes
Inline Side-by-side
Showing with 42 additions and 21 deletions
webitm-dis/ibase/webitm/ejb/dis/adv/SordBulkConf.java
View file @ 975ce056
......@@ -54,6 +54,8 @@ public String confirm(String tranId, String xtraParams, String forcedFlag)throws
String userId="",termId="";
String currCode1="",currCode2="",discount="";
String linenoStr="",itemCode="",quantityStr="";
String linedetnew=null,quantitydetNew=null;
StringBuffer xmlBuff = null;
String xmlString = null,retString = null;
String sysDate="";
......@@ -93,9 +95,11 @@ public String confirm(String tranId, String xtraParams, String forcedFlag)throws
if (tranId != null && tranId.trim().length() > 0)
{
System.out.println("tranId"+tranId+"]");
HashMap<String,ArrayList<HashMap<String,String>>> custCodeWiseHMap= new HashMap();
sql ="select sord_bulk.tran_id,sord_bulk.tran_date,sord_bulk.site_code,sord_bulk.item_ser," +
"sord_bulk.order_type,sord_bulk_det.cust_code,sord_bulk.confirmed,sord_bulk_det.item_code from sord_bulk , sord_bulk_det where sord_bulk.tran_id=sord_bulk_det.tran_id and sord_bulk.tran_id = ?";
sql ="select sord_bulk.tran_id,sord_bulk.tran_date,sord_bulk.site_code,sord_bulk.item_ser,"
+ "sord_bulk_det.line_no,sord_bulk_det.quantity, " +
"sord_bulk.order_type,sord_bulk_det.cust_code,sord_bulk.confirmed,sord_bulk_det.item_code from sord_bulk , sord_bulk_det where sord_bulk.tran_id=sord_bulk_det.tran_id and sord_bulk.tran_id = ? order by sord_bulk_det.cust_code,sord_bulk_det.item_code";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
......@@ -110,6 +114,9 @@ public String confirm(String tranId, String xtraParams, String forcedFlag)throws
custCode=checkNull(rs.getString("cust_code"));
confirmed=checkNull(rs.getString("confirmed"));
itemCodeBulkDet=checkNull(rs.getString("item_code"));
linedetnew=checkNull(rs.getString("line_no"));
quantitydetNew=checkNull(rs.getString("quantity"));
if("N".equalsIgnoreCase(confirmed))
{
......@@ -261,27 +268,33 @@ public String confirm(String tranId, String xtraParams, String forcedFlag)throws
tempMap.put("frt_term",frtTerm.trim());
tempMap.put("dlv_term",deliveryTerm);
sql="select * from sord_bulk_det where item_code= ? and cust_code= ?";
/*sql="select * from sord_bulk_det where item_code= ? and cust_code= ?";
pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1,itemCodeBulkDet);
pstmt1.setString(2,custCode);
rs1 = pstmt1.executeQuery();
if( rs1.next() )
{
if( rs1.next() )*/
/*{
linenoStr = rs1.getString("line_no");
itemCode = rs1.getString("item_code") == null ? " " : rs1.getString("item_code");
quantityStr = rs1.getString("quantity") == null ? "0" : rs1.getString("quantity") ;
custCodeDet = rs1.getString("cust_code") == null ? " " : rs1.getString("cust_code") ;
System.out.println("item_code["+itemCode+"]quantity["+quantityStr+"]custCodeDet["+custCodeDet+"]");
custCodeDet = rs1.getString("cust_code") == null ? " " : rs1.getString("cust_code") */;
//System.out.println("item_code["+itemCode+"]quantity["+quantityStr+"]custCodeDet["+custCodeDet+"]");
linenoStr=linedetnew;
itemCode=itemCodeBulkDet;
quantityStr=quantitydetNew;
custCodeDet=custCode;
if(quantityStr != null && quantityStr.trim().length()>0)
{
quantity=Double.parseDouble(quantityStr);
}
}
rs1.close();
System.out.println("item_code["+itemCode+"]quantity["+quantityStr+"]custCodeDet["+custCodeDet+"]");
//}
/*rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
pstmt1 = null;*/
sql2="select unit from item where item_code= ?";
pstmt2 = conn.prepareStatement(sql2);
pstmt2.setString(1, itemCodeBulkDet);
......@@ -354,7 +367,7 @@ public String confirm(String tranId, String xtraParams, String forcedFlag)throws
xmlBuff.append("<group0>");
xmlBuff.append("<description>").append("Group0 description").append("</description>");
xmlBuff.append("<Header0>");
xmlBuff.append("<objName><![CDATA[").append("sorder").append("]]></objName>");
xmlBuff.append("<objName><![CDATA[").append("sorder_bulk").append("]]></objName>");
xmlBuff.append("<pageContext><![CDATA[").append("1").append("]]></pageContext>");
xmlBuff.append("<objContext><![CDATA[").append("1").append("]]></objContext>");
xmlBuff.append("<editFlag><![CDATA[").append("A").append("]]></editFlag>");
......@@ -368,7 +381,7 @@ public String confirm(String tranId, String xtraParams, String forcedFlag)throws
xmlBuff.append("<taxInFocus><![CDATA[").append(false).append("]]></taxInFocus>");
xmlBuff.append("<description>").append("Header0 members").append("</description>");
xmlBuff.append("<Detail1 dbID=\"\" domID=\"1\" objName=\"sorder\" objContext=\"1\">");
xmlBuff.append("<Detail1 dbID=\"\" domID=\"1\" objName=\"sorder_bulk\" objContext=\"1\">");
xmlBuff.append("<attribute selected=\"N\" updateFlag=\"A\" status=\"N\" pkNames=\"\"/>");
xmlBuff.append("<sale_order/>");
xmlBuff.append("<order_type><![CDATA[" + orderType + "]]></order_type>");
......@@ -449,11 +462,13 @@ public String confirm(String tranId, String xtraParams, String forcedFlag)throws
unitMap = (String)payDetTranMap.get("unit");
System.out.println("itemCode["+itemCode+"]itemSerMap["+itemSerMap+"]quantityMap["+quantityMap+"]");
xmlBuff.append("<Detail2 dbID='' domID='" + lineNo + "' objName=\"sorder\" objContext=\"2\">");
xmlBuff.append("<Detail2 dbID='' domID='" + lineNo + "' objName=\"sorder_bulk\" objContext=\"2\">");
xmlBuff.append("<attribute pkNames=\"\" selected=\"N\" updateFlag=\"A\" status=\"N\" />");
xmlBuff.append("<sale_order/>");
xmlBuff.append("<remarks><![CDATA["+ "generated from POB transaction "+tranId+"]]></remarks>");
xmlBuff.append("<line_no><![CDATA["+lilineno1+"]]></line_no>");
xmlBuff.append("<site_code><![CDATA[" + siteCode.trim() + "]]></site_code>");
xmlBuff.append("<quantity isSrvCallOnChg='0'><![CDATA["+ quantityMap +"]]></quantity>");
xmlBuff.append("<item_code__ord isSrvCallOnChg='0'><![CDATA["+ itemCodeMap.trim() +"]]></item_code__ord>");
xmlBuff.append("<item_code isSrvCallOnChg='0'><![CDATA["+ itemCodeMap.trim() +"]]></item_code>");
xmlBuff.append("<rate isSrvCallOnChg='0'><![CDATA["+0 +"]]></rate>");
......@@ -653,9 +668,14 @@ private String saveData(String siteCode,String xmlString, Connection conn) throw
System.out.println("saving data...........");
InitialContext ctx = null;
String retString = null;
//Connection conn=null;
MasterStatefulLocal masterStateful = null; // for ejb3
try
{
//ConnDriver connDriver = new ConnDriver();
//conn = getConnection();
//conn=connDriver.getConnectDB("DriverITM");
//conn.setAutoCommit(false);
AppConnectParm appConnect = new AppConnectParm();
ctx = new InitialContext(appConnect.getProperty());
masterStateful = (MasterStatefulLocal)ctx.lookup("ibase/MasterStatefulEJB/local");
......@@ -689,7 +709,7 @@ public String confirmSaleorder(String businessObj, String tranIdFr,String xtraPa
String serviceURI = "";
String actionURI = "";
String sql = "";
Connection conn = null;
Connection conn1 = null;
PreparedStatement pStmt = null;
ResultSet rs = null;
int cnt = 0;
......@@ -697,15 +717,16 @@ public String confirmSaleorder(String businessObj, String tranIdFr,String xtraPa
try
{
ConnDriver connDriver = new ConnDriver();
conn = getConnection();
conn.setAutoCommit(false);
conn1 = getConnection();
//conn1=connDriver.getConnectDB("DriverITM");
conn1.setAutoCommit(false);
methodName = "gbf_post";
actionURI = "http://NvoServiceurl.org/" + methodName;
forcedFlag="";
System.out.println("forcedFlag Method["+forcedFlag+"]");
sql = "SELECT SERVICE_CODE,COMP_NAME FROM SYSTEM_EVENTS WHERE OBJ_NAME = ? AND EVENT_CODE = 'pre_confirm' ";
pStmt = conn.prepareStatement(sql);
pStmt = conn1.prepareStatement(sql);
pStmt.setString(1,businessObj);
rs = pStmt.executeQuery();
if ( rs.next() )
......@@ -724,7 +745,7 @@ public String confirmSaleorder(String businessObj, String tranIdFr,String xtraPa
rs=null;
}
sql = "SELECT SERVICE_URI FROM SYSTEM_EVENT_SERVICES WHERE SERVICE_CODE = ? ";
pStmt = conn.prepareStatement(sql);
pStmt = conn1.prepareStatement(sql);
pStmt.setString(1,serviceCode);
rs = pStmt.executeQuery();
if ( rs.next() )
......@@ -783,9 +804,9 @@ public String confirmSaleorder(String businessObj, String tranIdFr,String xtraPa
rs.close();
rs=null;
}
if( conn != null ){
conn.close();
conn = null;
if( conn1 != null ){
conn1.close();
conn1 = null;
}
}
catch(Exception e)
......
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