Skip to content

B
business-java
Commit b994d2f1 authored by dhirajchavan's avatar dhirajchavan
Browse files
Options

Added Code conn=getConnection(). 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@102872 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 420bc5b0
Show whitespace changes
Inline Side-by-side
Showing with 1062 additions and 510 deletions
webitm-dis/ibase/webitm/ejb/dis/adv/PorderClosePrc.java
View file @ b994d2f1
...@@ -11,6 +11,7 @@ package ibase.webitm.ejb.dis.adv; ...@@ -11,6 +11,7 @@ package ibase.webitm.ejb.dis.adv;
import ibase.webitm.utility.*; import ibase.webitm.utility.*;
import ibase.utility.CommonConstants; import ibase.utility.CommonConstants;
import ibase.utility.E12GenericUtility; import ibase.utility.E12GenericUtility;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.*; import ibase.webitm.ejb.*;
import ibase.system.config.*; import ibase.system.config.*;
...@@ -34,6 +35,7 @@ import java.util.Calendar; ...@@ -34,6 +35,7 @@ import java.util.Calendar;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
//import java.util.StringTokenizer; //import java.util.StringTokenizer;
import javax.ejb.Stateless; // added for ejb3 import javax.ejb.Stateless; // added for ejb3
import ibase.webitm.ejb.dis.DistCommon;
//import ibase.webitm.ejb.ValidatorEJB; //import ibase.webitm.ejb.ValidatorEJB;
//import ibase.webitm.ejb.dis.DistCommon; //import ibase.webitm.ejb.dis.DistCommon;
import ibase.webitm.ejb.dis.POrderAmdConf; import ibase.webitm.ejb.dis.POrderAmdConf;
...@@ -44,6 +46,8 @@ import org.w3c.dom.Document; ...@@ -44,6 +46,8 @@ import org.w3c.dom.Document;
import org.w3c.dom.Node; import org.w3c.dom.Node;
import org.w3c.dom.NodeList; import org.w3c.dom.NodeList;
@Stateless @Stateless
public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
PorderClosePrcRemote { PorderClosePrcRemote {
...@@ -57,7 +61,9 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -57,7 +61,9 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
CommonConstants commonConstants = new CommonConstants(); CommonConstants commonConstants = new CommonConstants();
Connection conn = null;
//DistCommon distCom=new DistCommon();
public String process() throws RemoteException, ITMException { public String process() throws RemoteException, ITMException {
return ""; return "";
...@@ -112,14 +118,13 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -112,14 +118,13 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
int TotStatusCnt = 0, totLineNo = 0; int TotStatusCnt = 0, totLineNo = 0;
String purcOrder = "", headerstatus = "", deptCode_po = "", empCode = "", deptCode_userlogin = ""; String purcOrder = "", headerstatus = "", deptCode_po = "", empCode = "", deptCode_userlogin = "";
String confirmed = "", loginEmpCode = ""; String confirmed = "", loginEmpCode = "";
Connection conn = null;
// Driver connection // Driver connection
try { try {
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
//Changes and Commented By Bhushan on 09-06-2016 :START conn = connDriver.getConnectDB("DriverITM");
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
conn.setAutoCommit(false); conn.setAutoCommit(false);
connDriver = null; connDriver = null;
} catch (Exception e) { } catch (Exception e) {
...@@ -306,7 +311,7 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -306,7 +311,7 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
"and porddet.item_code=item.item_code and " + "and porddet.item_code=item.item_code and " +
"porder.supp_code=supplier.supp_code " + "porder.supp_code=supplier.supp_code " +
"AND porddet.STATUS='O' and porddet.purc_order=? order by porddet.line_no"; "AND porddet.STATUS='O' and porddet.purc_order=? order by porddet.line_no";
System.out.println("sql..." + sql);
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, purcOrder); pstmt.setString(1, purcOrder);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
...@@ -466,9 +471,9 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -466,9 +471,9 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
Node childNode = null; Node childNode = null;
String errString = ""; String errString = "";
String childNodeName = ""; String childNodeName = "";
PreparedStatement pstmt = null; PreparedStatement pstmt = null,pstmt1 = null;
ResultSet rs = null; ResultSet rs = null,rs1 = null;
String sql = ""; String sql = "",sql1 = "";
StringBuffer xmlBuff = new StringBuffer(); StringBuffer xmlBuff = new StringBuffer();
SimpleDateFormat sdf = null; SimpleDateFormat sdf = null;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
...@@ -503,14 +508,16 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -503,14 +508,16 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
String ordDateStr = "", lineNo1 = "", empCodeQcApr = "",amdConfirmed="",amdNo="",poRetConfirmed=""; String ordDateStr = "", lineNo1 = "", empCodeQcApr = "",amdConfirmed="",amdNo="",poRetConfirmed="";
String purcOrder = ""; String purcOrder = "";
int forcount = 0, lineCnt = 0; int forcount = 0, lineCnt = 0;
String refMulIndSt="";
double oQty=0;
double convIndOrdQty=0;
genericUtility = new E12GenericUtility(); genericUtility = new E12GenericUtility();
Connection conn = null;
try { try {
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
//Changes and Commented By Bhushan on 09-06-2016 :START conn = connDriver.getConnectDB("DriverITM");
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
conn.setAutoCommit(false); conn.setAutoCommit(false);
connDriver = null; connDriver = null;
// String benefitType=""; // String benefitType="";
...@@ -520,6 +527,8 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -520,6 +527,8 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
String sysDateStr = sdf.format(currentDate2.getTime()); String sysDateStr = sdf.format(currentDate2.getTime());
System.out.println("Now the date is :=> " + sysDateStr); System.out.println("Now the date is :=> " + sysDateStr);
parentNodeList = detailDom.getElementsByTagName("Detail2"); parentNodeList = detailDom.getElementsByTagName("Detail2");
parentNodeListLength = parentNodeList.getLength(); parentNodeListLength = parentNodeList.getLength();
System.out.println("parentNodeListLength:::::::::" System.out.println("parentNodeListLength:::::::::"
...@@ -548,7 +557,7 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -548,7 +557,7 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
* Description:LineCnt:--taking total line count of those * Description:LineCnt:--taking total line count of those
* purchase order having status is 'O' parenNodeListLenght:-- * purchase order having status is 'O' parenNodeListLenght:--
*/ */
errString = itmDBAccessEJB.getErrorString("", "VCOPENC", "", errString = itmDBAccessEJB.getErrorString("", "VPCLOSECNF", "",
"", conn); "", conn);
return errString; return errString;
...@@ -588,7 +597,7 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -588,7 +597,7 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
//sql = "select amd_no,confirmed from poamd_hdr where purc_order=?"; //sql = "select amd_no,confirmed from poamd_hdr where purc_order=?";
sql = "select h.amd_no,h.confirmed,d.line_no__ord " + sql = "select h.amd_no,h.confirmed " +
"from poamd_hdr h,poamd_det d " + "from poamd_hdr h,poamd_det d " +
"where h.purc_order=d.purc_order and h.confirmed='N' " + "where h.purc_order=d.purc_order and h.confirmed='N' " +
"and d.line_no__ord=? " + "and d.line_no__ord=? " +
...@@ -644,7 +653,7 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -644,7 +653,7 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
// sql = "select tran_id,confirmed from porcp where purc_order=?"; // sql = "select tran_id,confirmed from porcp where purc_order=?";
sql = "select h.tran_id,h.confirmed " + sql = "select h.tran_id,h.confirmed " +
"from porcp h,porcpdet d " + "from porcp h,porcpdet d " +
"where h.purc_order=d.purc_order and h.confirmed='N' " + "where h.purc_order=d.purc_order and h.confirmed='N' and h.tran_ser='P-RCP' " +
"and h.purc_order=? " + "and h.purc_order=? " +
"and d.line_no__ord=? "; "and d.line_no__ord=? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
...@@ -696,8 +705,8 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -696,8 +705,8 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
sql = "select h.tran_id,h.confirmed " + sql = "select h.tran_id,h.confirmed " +
"from porcp h,porcpdet d " + "from porcp h,porcpdet d " +
"where h.purc_order=d.purc_order and h.confirmed='N' " + "where h.purc_order=d.purc_order and h.confirmed='N' " +
"and h.purc_order=? and h.tran_ser='P-RET'" + "and h.purc_order=? and h.tran_ser='P-RET' " +
"and d.line_no__ord=? "; " and d.line_no__ord=? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, purcOrder); pstmt.setString(1, purcOrder);
pstmt.setString(2, lineNo); pstmt.setString(2, lineNo);
...@@ -742,6 +751,10 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -742,6 +751,10 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql = " select purc_order,ord_date,pord_type,supp_code,site_code__dlv,site_code__ord,site_code__bill," sql = " select purc_order,ord_date,pord_type,supp_code,site_code__dlv,site_code__ord,site_code__bill,"
+ " status,status_date,dept_code,emp_code,order_db,item_ser,tax_opt,cr_term,ord_amt,tax_amt,tot_amt," + " status,status_date,dept_code,emp_code,order_db,item_ser,tax_opt,cr_term,ord_amt,tax_amt,tot_amt,"
+ " curr_code,exch_rate,tax_chap,tax_class,tax_env,remarks,tax_date,proj_code,sales_pers,comm_perc," + " curr_code,exch_rate,tax_chap,tax_class,tax_env,remarks,tax_date,proj_code,sales_pers,comm_perc,"
...@@ -1203,6 +1216,8 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -1203,6 +1216,8 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
dlvQty = rs.getDouble("dlv_qty"); dlvQty = rs.getDouble("dlv_qty");
status = checkNull(rs.getString("status")); status = checkNull(rs.getString("status"));
// statusDate = rs.getTimestamp("status_date"); // statusDate = rs.getTimestamp("status_date");
refMulIndSt=status;
System.out.println("refMulIndSt@@@"+refMulIndSt);
taxClass = checkNull(rs.getString("tax_class")); taxClass = checkNull(rs.getString("tax_class"));
taxChap = checkNull(rs.getString("tax_chap")); taxChap = checkNull(rs.getString("tax_chap"));
taxEnv = checkNull(rs.getString("tax_env")); taxEnv = checkNull(rs.getString("tax_env"));
...@@ -1428,6 +1443,7 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -1428,6 +1443,7 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
System.out.println("@@@@@2: retString:" + retString); System.out.println("@@@@@2: retString:" + retString);
System.out.println("--retString finished--"); System.out.println("--retString finished--");
if (retString.indexOf("Success") > -1) { if (retString.indexOf("Success") > -1) {
System.out.println("comming into confirm function"); System.out.println("comming into confirm function");
POrderAmdConf Conf = new POrderAmdConf(); POrderAmdConf Conf = new POrderAmdConf();
...@@ -1450,115 +1466,178 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -1450,115 +1466,178 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
//Calling confirm function of purchase order confirm //Calling confirm function of purchase order confirm
String forcedFlag = ""; String forcedFlag = "";
errString = Conf.confirm(tranIdPe, xtraParams, forcedFlag); errString = Conf.ConfirmPordAmd(tranIdPe, conn);//(tranIdPe, xtraParams, forcedFlag);
System.out.println("errString@conf@"+errString);
if(errString.indexOf("Success")>-1 || errString.equalsIgnoreCase("PRCUSUCCES")||errString.equals("PRCUSUCCES")||errString.equals("PRCUSUCCES")) if(errString==null||errString.trim().length()==0 || errString.indexOf("Success")>-1 || errString.equalsIgnoreCase("PRCUSUCCES")||errString.equals("PRCUSUCCES")||errString.equals("PRCUSUCCES"))
{ {
//System.out.println("status_date="+sdf.format(sysDateStr).toString());
try {
double ordQty=0 ,totalOrdqty=0,indOrdQty=0;;
Timestamp sysDate1 = null;
SimpleDateFormat sdf1 = null;
String sysDateStr1 = "",loginEmpCode="",errString1="";
double indQty = 0,orderQty=0;
int cnt = 0, detCnt = 0,mulPoIndRef=0;
int updCnt1 = 0,mulPoIndRefCnt=0,updCnt = 0;
int indOQty=0;
DistCommon distCommon = new DistCommon();
Calendar currentDate = Calendar.getInstance();
sdf1 = new SimpleDateFormat(
genericUtility.getApplDateFormat());
sysDateStr1 = sdf1.format(currentDate.getTime());
System.out
.println("after conf method Now the date is :=> "
+ sysDateStr1);
sysDate1 = Timestamp.valueOf(genericUtility
.getValidDateString(sysDateStr1,
genericUtility.getApplDateFormat(),
genericUtility.getDBDateFormat())
+ " 00:00:00.0");
String userId = genericUtility.getValueFromXTRA_PARAMS(
xtraParams, "loginCode");
System.out.println("dlvQty@@At before"+dlvQty);
loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
System.out.println("dlvQty@@At before"+dlvQty);
System.out.println("loginEmpCode@@"+loginEmpCode);
sql = " update poamd_hdr set confirmed = 'Y',conf_date = ?, emp_code__aprv = ? where amd_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1, sysDate1);
pstmt.setString(2, loginEmpCode);
pstmt.setString(3, tranIdPe);
cnt = pstmt.executeUpdate();
System.out.println("cnt@@update@"+cnt);
pstmt.close();
pstmt = null;
rs=null;
//rs.close();
if(indNo!=null)
{
/* Below code is used for one indent one porder case and also checking if receipt exist then set indent status should be closed'C'*/
double indQty=0;
int cnt=0,detCnt=0; sql1 = "SELECT LINE_NO__ORD,IND_NO FROM POAMD_DET WHERE amd_no=? AND purc_order=? ";
sql = " select quantity from indent where ind_no = ? "; pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, tranIdPe);
pstmt1.setString(2, purcOrder);
rs1 = pstmt1.executeQuery();
while (rs1.next()) {
lineNo1 = rs1.getString(1);
indNo = rs1.getString(2);
System.out.println("lineNo@@newhile" + lineNo1);
System.out.println("indNo@@newhile" + indNo);
if (indNo != null) {
System.out
.println("Comming after success msg@@");
/*
* Below code is used for one indent one porder
* case and also checking if receipt exist then
* set indent status should be closed'C'
*/
sql = " select quantity,ord_qty from indent where ind_no = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if (rs.next()) {
{ indQty = rs.getDouble(1);
indQty=rs.getDouble(1); ordQty=rs.getDouble(2);
orderQty=ordQty;
} System.out.println("orderQty@@for dlvQty@@"+orderQty);
System.out.println("indQty@@"+indQty); System.out.println("ordQty@@for NOT dlvQty@@"+ordQty);
System.out.println("indQty@@" + indQty);
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql = " select sum(d.quantity) from porder h,porddet d where h.purc_order=d.purc_order and d.purc_order=? and d.ind_no=? "; sql = " select d.quantity,d.dlv_qty ,d.unit,d.unit__std ,d.item_code from porder h,porddet d where h.purc_order=d.purc_order and d.purc_order=? and d.ind_no=? and d.line_no=? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, purcOrder); pstmt.setString(1, purcOrder);
pstmt.setString(2, indNo); pstmt.setString(2, indNo);
pstmt.setString(3, lineNo1);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if (rs.next()) {
{ sumPoQty = rs.getDouble(1);
sumPoQty=rs.getDouble(1); dlvQty=rs.getDouble(2);
unit=rs.getString(3);
} unitStd=rs.getString(4);
System.out.println("sumPoQty@@"+sumPoQty); itemCode=rs.getString(5);
}
System.out.println("sumPoQty@@" + sumPoQty);
System.out.println("dlvQty@@" + dlvQty);
System.out.println("unit@@" + unit);
System.out.println("unitStd@@" + unitStd);
System.out.println("itemCode@@" + itemCode);
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql = " select count(1) from porder a, porddet b " sql = " select count(1) from porder a, porddet b "
+ "where a.purc_order = b.purc_order " + "where a.purc_order = b.purc_order "
+ " and a.purc_order <> ? " + " and a.purc_order <> ? "
+ "and b.ind_no = ? " + "and b.ind_no = ? and b.status='O' ";
+ "and (case when a.status is null then 'O' else a.status end) = 'O' " /* + "and (case when a.status is null then 'O' else a.status end) = 'O' "
+ "and (case when b.status is null then 'O' else b.status end) = 'O'"; + "and (case when b.status is null then 'O' else b.status end) = 'O'";*/
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder); pstmt.setString(2, purcOrder);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if (rs.next()) {
{ cnt = rs.getInt(1);
cnt=rs.getInt(1);
} }
System.out.println("cnt@@"+cnt); System.out.println("cnt@@useless" + cnt);
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
if (sumPoQty == indQty) {
if ((dlvQty > 0)) {
System.out
.println("comming into dlvQty>0 condition@@");
System.out.println("dlvQty@@At (sumPoQty == indQty)@(dlvQty>0)"+dlvQty);
/* total qty of purchase order detail is equal to indent quantity*/ totalOrdqty = sumPoQty - dlvQty;
if(sumPoQty==indQty) System.out.println("totalOrdqty@@"+totalOrdqty);
{
System.out.println("comming into quantity==indQty condition@@");
int updCnt=0;
sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? "; convIndOrdQty=distCommon.convQtyFactor(unit, unitStd, itemCode, totalOrdqty, conn) ;
pstmt = conn.prepareStatement(sql); System.out.println("convIndOrdQty"+convIndOrdQty);
pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder);
pstmt.setString(3, lineNo1);
updCnt = pstmt.executeUpdate();
System.out.println("porder status updated@@"+updCnt);
//rs.close();
//rs = null;
pstmt.close();
pstmt = null;
sql = " update indent set status = 'A' where ind_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); indOrdQty=orderQty-convIndOrdQty;
updCnt = pstmt.executeUpdate(); System.out.println("indOrdQty@Partly@[orderQty-convIndOrdQty]"+indOrdQty);
System.out.println("Indent status updated@@"+updCnt);
//rs.close();
//rs = null; if(sumPoQty==dlvQty){
pstmt.close(); sql=null;
pstmt = null; sql = " update indent set status = 'C', status_date=? ,ord_qty="+indOQty+" where ind_no = ? ";
if((dlvQty>0)) }
else if((sumPoQty == indQty)&&(sumPoQty>dlvQty))
{ {
//for partially Receipt
sql=null;
sql=" update indent set status = 'C', status_date=? ,ord_qty="+indOrdQty+" where ind_no = ? ";
}
double totalOrdqty=indQty-dlvQty;
System.out.println("comming into dlvQty>0 condition@@");
int updCnt1=0;
sql = " update indent set status = 'C',ord_qty="+totalOrdqty+" where ind_no = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setTimestamp(1, sysDate1);
pstmt.setString(2, indNo);
updCnt1 = pstmt.executeUpdate(); updCnt1 = pstmt.executeUpdate();
System.out.println("Indent status updated@@"+updCnt1); System.out
.println("Indent status updated@@"
+ updCnt1);
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? "; sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? ";
...@@ -1566,234 +1645,370 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -1566,234 +1645,370 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder); pstmt.setString(2, purcOrder);
//lineNo1 // lineNo1
pstmt.setString(3, lineNo1); pstmt.setString(3, lineNo1);
updCnt = pstmt.executeUpdate(); updCnt = pstmt.executeUpdate();
System.out.println("porder status updated@@"+updCnt); System.out
.println("porder status updated@@"+ updCnt);
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
} else
}else if(dlvQty==0) //if((dlvQty==0))
{ {
totalOrdqty = sumPoQty - dlvQty;
System.out.println("totalOrdqty@@"+totalOrdqty);
convIndOrdQty=distCommon.convQtyFactor(unit, unitStd, itemCode, totalOrdqty, conn) ;
System.out.println("convIndOrdQty"+convIndOrdQty);
indOrdQty=orderQty-convIndOrdQty;
System.out.println("indOrdQty@Partly@[orderQty-convIndOrdQty]"+indOrdQty);
System.out.println("dlvQty@@At (sumPoQty == indQty)@(dlvQty==0)"+dlvQty);
System.out
.println("comming into quantity==indQty condition@@");
//updCnt = 0;
System.out.println("comming into dlvQty==0 condition@@");
int updCnt1=0;
double ordQty=0.0;
sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? "; sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder); pstmt.setString(2, purcOrder);
pstmt.setString(3, lineNo1); pstmt.setString(3, lineNo1);
updCnt1 = pstmt.executeUpdate(); updCnt = pstmt.executeUpdate();
System.out.println("porder status updated@@"+updCnt1); System.out
.println("porder status updated@@"
+ updCnt);
// rs.close();
// rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
//select ord_qty from indent where ind_no=? System.out.println("sysDate1@@@-->"
sql = " select ord_qty from indent where ind_no=? "; + sysDate1);
// if(indOrdQty==0)
// {
sql = " update indent set status = 'A' ,status_date=? ,ord_qty=? where ind_no = ? ";
// }else
// {
// sql = " update indent set status = 'A' ,status_date=? ,ord_qty=? where ind_no = ? ";
// }
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setTimestamp(1, sysDate1);
rs= pstmt.executeQuery(); pstmt.setDouble(2, indOrdQty);
if(rs.next()) pstmt.setString(3, indNo);
{
ordQty=rs.getDouble(1);
}
System.out.println("Indent status updated@@"+updCnt); updCnt = pstmt.executeUpdate();
System.out
.println("Indent status updated@@"
+ updCnt);
// rs.close();
// rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
System.out.println("comming into ordQty==0 condition@@"); }
sql = " update indent set status = 'A' ,ord_qty=0 where ind_no = ? ";//,ord_qty=0 }
if (sumPoQty < indQty) {
if ((dlvQty > 0)) {
System.out
.println("comming into dlvQty>0 condition@@");
updCnt1 = 0;
System.out.println("dlvQty@@At (sumPoQty <indQty)@(dlvQty>0)"+dlvQty);
System.out.println("dlvQty@Partly@dlvQty>0 @"+dlvQty);
System.out.println("sumPoQty@Partly@dlvQty>0 @"+sumPoQty);
totalOrdqty = sumPoQty - dlvQty;
System.out.println("totalOrdqty@@"+totalOrdqty);
convIndOrdQty=distCommon.convQtyFactor(unit, unitStd, itemCode, totalOrdqty, conn) ;
System.out.println("convIndOrdQty"+convIndOrdQty);
indOrdQty=orderQty-convIndOrdQty;
System.out.println("indOrdQty@Partly@[orderQty-convIndOrdQty]"+indOrdQty);
sql=null;
sql = " select count(1) from porddet where ind_no = ? and status='O' ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
updCnt = pstmt.executeUpdate(); rs = pstmt.executeQuery();
System.out.println("Indent status updated@@"+updCnt); if (rs.next()) {
mulPoIndRef=rs.getInt(1);
System.out.println("count@@ind in multiple po@cnt@"+mulPoIndRef);
}
rs.close();
rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql=null;
System.out.println("refMulIndSt@@"+refMulIndSt);
if(sumPoQty==dlvQty){
System.out
.println("comming into Full RCP condition@(sumPoQty==dlvQty)@");
sql=null;
sql = " update indent set status = 'C', status_date=?,ord_qty="+indOrdQty+" where ind_no = ? ";
} }
else if((mulPoIndRef>0) && (sumPoQty!=dlvQty) )
{
System.out
.println("comming into multiple po ref against indent---RCP condition@(mulPoIndRef>1) && (sumPoQty!=dlvQty)@");
}else if(sumPoQty<indQty) sql=null;
sql=" update indent set status = 'O', status_date=? ,ord_qty="+indOrdQty+" where ind_no = ? ";
}else if((cnt>0))
{ {
System.out.println("comming into quantity<indQty condition@@"); System.out
int updCnt=0; .println("comming into multiple po ref against indent---RCP condition@(cnt>0)@");
sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? "; sql=null;
pstmt = conn.prepareStatement(sql); sql=" update indent set status = 'O', status_date=? ,ord_qty="+indOrdQty+" where ind_no = ? ";
pstmt.setString(1, indNo); }else if((cnt<=0))
pstmt.setString(2, purcOrder); {
pstmt.setString(3, lineNo1); if(orderQty==0 || indOrdQty==0)
updCnt = pstmt.executeUpdate(); {
System.out.println("porder status updated@@"+updCnt); double orQty=0;
//rs.close(); System.out
//rs = null; .println("comming into multiple po ref against indent---RCP condition@(orderQty==0)@");
pstmt.close();
pstmt = null;
sql = " update indent set status = 'O' where ind_no = ? "; sql=null;
pstmt = conn.prepareStatement(sql); sql=" update indent set status = 'A', status_date=? ,ord_qty="+orQty+" where ind_no = ? ";
pstmt.setString(1, indNo); }else
updCnt = pstmt.executeUpdate(); {
System.out.println("Indent status updated@@"+updCnt); System.out
//rs.close(); .println("comming into multiple po ref against indent---RCP condition@(cnt<=0)@");
//rs = null;
pstmt.close(); sql=null;
pstmt = null; sql=" update indent set status = 'C', status_date=? ,ord_qty="+indOrdQty+" where ind_no = ? ";
}
}else if(cnt>0) }else if((cnt>0) && (mulPoIndRef>0) )
{ {
/*Case one indent multiple purchase order*/ System.out
System.out.println("comming into cnt>0 condition@@for multipo"); .println("comming into multiple po ref against indent---RCP condition@(cnt>0)@");
int updCnt=0;
sql=null;
sql=" update indent set status = 'O', status_date=? ,ord_qty="+indOrdQty+" where ind_no = ? ";
}else if((sumPoQty < indQty)&&(sumPoQty>dlvQty))
{
System.out
.println("comming into Partly RCP condition@(sumPoQty!=dlvQty)@");
sql=null;
sql=" update indent set status = 'C', status_date=? ,ord_qty="+indOrdQty+" where ind_no = ? ";
}
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1, sysDate1);
pstmt.setString(2, indNo);
updCnt1 = pstmt.executeUpdate();
System.out
.println("Indent status updated@@"
+ updCnt1);
pstmt.close();
pstmt = null;
sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? "; sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder); pstmt.setString(2, purcOrder);
// lineNo1
pstmt.setString(3, lineNo1); pstmt.setString(3, lineNo1);
updCnt = pstmt.executeUpdate(); updCnt = pstmt.executeUpdate();
System.out.println("porder status updated@@"+updCnt); System.out
//rs.close(); .println("porder status updated@@"
//rs = null; + updCnt);
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql = " update indent set status = 'O' where ind_no = ? "; }else
pstmt = conn.prepareStatement(sql);
{/*if(dlvQty==0)*/
System.out
.println("comming into quantity<indQty condition@@");
System.out.println("dlvQty@@At (sumPoQty == indQty)@(dlvQty==0)"+dlvQty);
System.out.println("sumPoQty@@-->"+sumPoQty);
System.out.println("ordQty@@-->"+ordQty);
totalOrdqty = sumPoQty - dlvQty;
convIndOrdQty=distCommon.convQtyFactor(unit, unitStd, itemCode, totalOrdqty, conn) ;
System.out.println("convIndOrdQty"+convIndOrdQty);
indOrdQty=orderQty-convIndOrdQty;
System.out.println("ordQty1@@-->"+indOrdQty);
System.out
.println("ordQty1 calc@@"+indOrdQty);
sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder);
pstmt.setString(3, lineNo1);
updCnt = pstmt.executeUpdate(); updCnt = pstmt.executeUpdate();
System.out.println("Indent status updated@@"+updCnt); System.out
//rs.close(); .println("porder status updated@@"
//rs = null; + updCnt);
// rs.close();
// rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql=null;
} sql = " select count(1) from porddet where ind_no = ? and status='O' ";
/* above code is used for one indent one porder case and also checking if
* receipt exist then set indent status should be closed'C'*/
//select count(1) from porddet d,indent i where d.ind_no=i.ind_no and d.ind_no='7180002202 ' and d.status='O';
sql = " select count(*) from porddet d,indent i where d.ind_no=i.ind_no and d.ind_no=? and d.status='O' ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if (rs.next()) {
{ mulPoIndRefCnt=rs.getInt(1);
detCnt=rs.getInt(1); System.out.println("count@@ind in multiple po@cnt@"+mulPoIndRefCnt);
} }
System.out.println("detCnt@@"+detCnt);
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
if(detCnt>0) sql=null;
if(mulPoIndRefCnt>0){
System.out.println("mulPoIndRefCnt>0@dlvQty<=0");
sql=null;
sql = " update indent set status = 'O' , status_date=? ,ord_qty=? where ind_no = ? ";
}else if(cnt>0){
sql=null;
System.out.println("(cnt>0)@dlvQty<=0");
sql = " update indent set status = 'O' , status_date=? ,ord_qty=? where ind_no = ? ";
}else if(mulPoIndRefCnt<=0){
if(indOrdQty==0 || indOrdQty==0.0)
{ {
/*Case one indent multiple purchase order*/ System.out.println("mulPoIndRefCnt<=0@dlvQty<=0");
System.out.println("comming into cnt>0 condition@@for multipo"); sql=null;
int updCnt=0; sql = " update indent set status = 'A' , status_date=? ,ord_qty=? where ind_no = ? ";
sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); }else
pstmt.setString(2, purcOrder); {
pstmt.setString(3, lineNo1);
updCnt = pstmt.executeUpdate();
System.out.println("porder status updated@@"+updCnt);
//rs.close();
//rs = null;
pstmt.close();
pstmt = null;
sql = " update indent set status = 'O' where ind_no = ? "; System.out.println("mulPoIndRefCnt<=0@dlvQty<=0");
pstmt = conn.prepareStatement(sql); sql=null;
sql = " update indent set status = 'C' , status_date=? ,ord_qty=? where ind_no = ? ";
pstmt.setString(1, indNo); }
updCnt = pstmt.executeUpdate();
System.out.println("Indent status updated@@"+updCnt); }else if(cnt==0)
//rs.close();
//rs = null;
pstmt.close();
pstmt = null;
if(dlvQty>0)
{ {
double totalOrdqty1=indQty-dlvQty; System.out.println("comming into(cnt<=0)@dlvQty<=0");
System.out.println("comming into dlvQty>0 condition@@"); if(indOrdQty==0){
int updCnt1=0; System.out.println("(cnt<=0)@ordQty==0@dlvQty<=0");
sql = " update indent set status = 'C' , ord_qty="+totalOrdqty1+" where ind_no = ? "; sql = " update indent set status = 'A' , status_date=? ,ord_qty=? where ind_no = ? ";
pstmt = conn.prepareStatement(sql); }else
{
System.out.println("(cnt<=0)@dlvQty<=0");
sql = " update indent set status = 'C' , status_date=? ,ord_qty=? where ind_no = ? ";
}
}else if(indOrdQty==0 || indOrdQty==0.0)
{
sql=null;
System.out.println("mulPoIndRefCnt<=0@dlvQty<=0@ordQty1==0");
sql = " update indent set status = 'A' , status_date=? ,ord_qty=? where ind_no = ? ";
}else
{
sql=null;
System.out.println("mulPoIndRefCnt<=0@dlvQty<=0@ordQty1>0");
//one indent used in different po(Partially).
sql = " update indent set status = 'O' , status_date=? ,ord_qty=? where ind_no = ? ";
pstmt.setString(1, indNo); }
updCnt1 = pstmt.executeUpdate();
System.out.println("Indent status updated@@"+updCnt1);
pstmt.close();
pstmt = null;
sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1, sysDate1);
pstmt.setDouble(2, indOrdQty);
pstmt.setString(3, indNo);
pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder);
//lineNo1
pstmt.setString(3, lineNo1);
updCnt = pstmt.executeUpdate(); updCnt = pstmt.executeUpdate();
System.out.println("porder status updated@@"+updCnt); System.out
.println("Indent status updated@@"
+ updCnt);
// rs.close();
// rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
}
} }
}
}else }
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
try {
errString1 = itmDBAccessEJB.getErrorString(" ", "VMPOSUC", userId);
return errString1;
} catch (Exception e) {
e.printStackTrace();
if(errString1==null)
{System.out.println("got errString exception"+e.getMessage());
conn.rollback();
conn.close();
}
// TODO: handle exception
}finally
{ {
System.out.println("comming into det<0 condition@@for multipo"); if(errString1!=null || errString1.trim().length()>0||errString1.indexOf("VMPOSUC")>-1)
int updCnt=0; {
System.out.println("Connection commiting@dj");
conn.commit();
conn.close();
}
}
sql = " update porddet set status = 'C' where ind_no = ? and purc_order=? and line_no=? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder);
pstmt.setString(3, lineNo1);
updCnt = pstmt.executeUpdate();
System.out.println("porder status updated@@"+updCnt);
//rs.close();
//rs = null;
pstmt.close();
pstmt = null;
sql = " update indent set status = 'A' ,ord_qty=0 where ind_no = ? ";//insert ,ord_qty=0
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo);
updCnt = pstmt.executeUpdate();
System.out.println("Indent status updated@@"+updCnt);
//rs.close();
//rs = null;
pstmt.close();
pstmt = null;
} }
catch (Exception e) {
e.printStackTrace();
System.out.println("Exception after confirmed@@"+e.getMessage());
errString = e.getMessage();
System.out.println("errString@@--"+errString);
throw new ITMException(e);
}
System.out.println("comming into new cof err condition@@"+errString);
return errString;
} }
return errString; else
{
System.out.println("ErrorString not null");
conn.rollback();
conn.close();
} }
System.out.println("After confiremed error String-->" System.out.println("After confiremed error String-->"
+ errString); + errString);
return errString; return errString;
} }
return retString;
} catch (Exception e) { } catch (Exception e) {
try { try {
conn.rollback(); conn.rollback();
...@@ -1809,11 +2024,12 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -1809,11 +2024,12 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
throw new ITMException(e); throw new ITMException(e);
} }
} finally { } finally {
System.out.println("errorString...." + errString);
System.out.println("Closing Connection...."); System.out.println("Closing Connection....");
try { try {
if (conn != null && !conn.isClosed()) { if (conn != null && !conn.isClosed()) {
// conn.rollback(); // conn.rollback();
System.out.println("finally@@commit");
conn.commit(); conn.commit();
conn.close(); conn.close();
conn = null; conn = null;
...@@ -1836,13 +2052,54 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -1836,13 +2052,54 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
return input; return input;
} }
/*public String getUserInfo()throws ITMException{
String xtraParams="";
StringBuffer userInfoStr = new StringBuffer();
String userId = "", loginEmpCode = "", loginSiteCode = "", entityCode = "", profileId = "",
userType = "", chgTerm = "";
try{
E12GenericUtility genericUtility = new E12GenericUtility();
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginEmpCode");
loginSiteCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginSiteCode");
entityCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"entityCode");
profileId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"profileId");
userType = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"userType");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chgTerm");
System.out.println("xtraParams is @@@@@ " + xtraParams);
userInfoStr.append("<UserInfo>");
userInfoStr.append("<loginCode>").append("<![CDATA["+userId+"]]>").append("</loginCode>\r\n");
userInfoStr.append("<empCode>").append("<![CDATA["+loginEmpCode+"]]>").append("</empCode>\r\n");
userInfoStr.append("<siteCode>").append("<![CDATA["+loginSiteCode+"]]>").append("</siteCode>\r\n");
userInfoStr.append("<entityCode>").append("<![CDATA["+entityCode+"]]>").append("</entityCode>\r\n");
userInfoStr.append("<profileId>").append("<![CDATA["+profileId+"]]>").append("</profileId>\r\n");
userInfoStr.append("<userType>").append("<![CDATA["+userType+"]]>").append("</userType>\r\n");
userInfoStr.append("<remoteHost>").append("<![CDATA["+chgTerm+"]]>").append("</remoteHost>\r\n");
userInfoStr.append("</UserInfo>");
}
catch (Exception e){
throw new ITMException(e);
}
return userInfoStr.toString();
}*/
public String saveData(String siteCode, String xmlString, Connection conn) public String saveData(String siteCode, String xmlString, Connection conn)
throws ITMException { throws ITMException {
System.out.println("saving data..........."); System.out.println("saving data...........");
InitialContext ctx = null; InitialContext ctx = null;
String retString = null; String retString = null;
MasterStatefulLocal masterStateful = null; // for ejb3 MasterStatefulLocal masterStateful = null; // for ejb3
//ibase.utility.UserInfoBean userInfo=null;
try { try {
AppConnectParm appConnect = new AppConnectParm(); AppConnectParm appConnect = new AppConnectParm();
ctx = new InitialContext(appConnect.getProperty()); ctx = new InitialContext(appConnect.getProperty());
masterStateful = (MasterStatefulLocal) ctx masterStateful = (MasterStatefulLocal) ctx
...@@ -1854,16 +2111,23 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal, ...@@ -1854,16 +2111,23 @@ public class PorderClosePrc extends ProcessEJB implements PorderClosePrcLocal,
authencate[1] = ""; authencate[1] = "";
System.out.println("xmlString to masterstateful [" + xmlString System.out.println("xmlString to masterstateful [" + xmlString
+ "]"); + "]");
retString = masterStateful.processRequest(authencate, siteCode, //UserInfoBean userInfo = getUserInfo();
true, xmlString, true, conn);
//String userInfo=getUserInfo();
//System.out.println("userInfo@at masterSate@"+userInfo.toString());
retString = masterStateful.processRequest(authencate, siteCode,true, xmlString, true, conn);
// UserInfoBean userInfo = getUserInfo();
//retString = masterStateful.processRequest(userInfo, xmlString, true, conn);
System.out.println("--retString - -" + retString); System.out.println("--retString - -" + retString);
} catch (ITMException itme) { } catch (ITMException itme) {
System.out.println("ITMException :CreateDistOrder :saveData :==>"); System.out.println("ITMException :PorderClosePrc :saveData :==>");
throw itme; throw itme;
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
System.out.println("Exception :CreateDistOrder :saveData :==>"); System.out.println("Exception :PorderClosePrc :saveData :==>");
throw new ITMException(e); throw new ITMException(e);
} }
return retString; return retString;
......
webitm-dis/ibase/webitm/ejb/dis/adv/PorderOpenPrc.java
View file @ b994d2f1
...@@ -4,6 +4,7 @@ package ibase.webitm.ejb.dis.adv; ...@@ -4,6 +4,7 @@ package ibase.webitm.ejb.dis.adv;
import ibase.webitm.utility.*; import ibase.webitm.utility.*;
import ibase.utility.CommonConstants; import ibase.utility.CommonConstants;
import ibase.utility.E12GenericUtility; import ibase.utility.E12GenericUtility;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.*; import ibase.webitm.ejb.*;
import ibase.system.config.*; import ibase.system.config.*;
...@@ -47,7 +48,7 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -47,7 +48,7 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
CommonConstants commonConstants = new CommonConstants(); CommonConstants commonConstants = new CommonConstants();
Connection conn = null;
public String process() throws RemoteException,ITMException public String process() throws RemoteException,ITMException
{ {
return ""; return "";
...@@ -102,14 +103,12 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -102,14 +103,12 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
String purcOrder="",confirmed="",empCode="",loginEmpCode="",deptCode_po="",deptCode_userlogin=""; String purcOrder="",confirmed="",empCode="",loginEmpCode="",deptCode_po="",deptCode_userlogin="";
String headerstatus=""; String headerstatus="";
SimpleDateFormat sdf = null; SimpleDateFormat sdf = null;
Connection conn = null;
try try
{ {
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
//Changes and Commented By Bhushan on 09-06-2016 :START
//conn = connDriver.getConnectDB("DriverITM"); //conn = connDriver.getConnectDB("DriverITM");
conn = getConnection(); conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
conn.setAutoCommit(false); conn.setAutoCommit(false);
connDriver = null; connDriver = null;
} }
...@@ -177,6 +176,11 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -177,6 +176,11 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
{ {
errString = itmDBAccessEJB.getErrorString("","VPCANC","","",conn); errString = itmDBAccessEJB.getErrorString("","VPCANC","","",conn);
return errString; return errString;
}else
if(headerstatus.equals("C")||headerstatus.equalsIgnoreCase("C"))
{
errString = itmDBAccessEJB.getErrorString("","VPCLOSE","","",conn);
return errString;
} }
rs.close(); rs.close();
rs = null; rs = null;
...@@ -467,9 +471,9 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -467,9 +471,9 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
//For Header //For Header
PreparedStatement pstmt = null; PreparedStatement pstmt = null,pstmt1 = null;
ResultSet rs = null; ResultSet rs = null,rs1=null;
String sql=""; String sql="",sql1="";
StringBuffer xmlBuff = new StringBuffer(); StringBuffer xmlBuff = new StringBuffer();
SimpleDateFormat sdf=null; SimpleDateFormat sdf=null;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB(); ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
...@@ -497,21 +501,20 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -497,21 +501,20 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
String unitRate = "",retString="", unitStd = ""; String unitRate = "",retString="", unitStd = "";
String frtType = ""; String frtType = "";
double frtRate = 0, frtAmtQty = 0, frtAmtFixed = 0; double frtRate = 0, frtAmtQty = 0, frtAmtFixed = 0;
String lineNo=""; String lineNo="",statusHdr="";
String refDateStr = ""; String refDateStr = "";
String taxDateStr = ""; String taxDateStr = "";
String ordDateStr = "",lineNo1="",empCodeQcApr="",poHdrStatus=""; String ordDateStr = "",lineNo1="",empCodeQcApr="",poHdrStatus="";
String purcOrder=null; String purcOrder=null;
int forcount=0,lineCnt=0; int forcount=0,lineCnt=0;
genericUtility= new E12GenericUtility();
genericUtility= new E12GenericUtility();
Connection conn = null;
try try
{ {
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
//Changes and Commented By Bhushan on 09-06-2016 :START
//conn = connDriver.getConnectDB("DriverITM"); //conn = connDriver.getConnectDB("DriverITM");
conn = getConnection(); conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
conn.setAutoCommit(false); conn.setAutoCommit(false);
connDriver = null; connDriver = null;
sdf = new SimpleDateFormat(genericUtility.getApplDateFormat()); sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
...@@ -539,10 +542,24 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -539,10 +542,24 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql = "select status from porder where purc_order=?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, purcOrder);
rs = pstmt.executeQuery();
if (rs.next()) {
statusHdr = rs.getString(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("statusHdr@@@"+statusHdr);
if ((lineCnt == parentNodeListLength) && (statusHdr.equals("C"))) {
if (lineCnt == parentNodeListLength) {
/* /*
* Error Msg=Use Po close transaction for fully closed po. * Error Msg=Use Po open option for full open po.
* Description:LineCnt:--taking total line count of those * Description:LineCnt:--taking total line count of those
* purchase order having status is 'O' parenNodeListLenght:--*/ * purchase order having status is 'O' parenNodeListLenght:--*/
...@@ -550,6 +567,8 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -550,6 +567,8 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
"", conn); "", conn);
return errString; return errString;
} }
sql = " select purc_order,ord_date,pord_type,supp_code,site_code__dlv,site_code__ord,site_code__bill," sql = " select purc_order,ord_date,pord_type,supp_code,site_code__dlv,site_code__ord,site_code__bill,"
...@@ -1197,57 +1216,180 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -1197,57 +1216,180 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
// String tranIdPe; // String tranIdPe;
String forcedFlag=""; String forcedFlag="";
errString = Conf.confirm(tranIdPe, xtraParams, forcedFlag); errString = Conf.ConfirmPordAmd(tranIdPe, conn);//(tranIdPe, xtraParams, forcedFlag);
System.out.println("errString@conf@"+errString);
if(errString==null||errString.trim().length()==0 || errString.indexOf("Success")>-1 || errString.equalsIgnoreCase("PRCUSUCCES")||errString.equals("PRCUSUCCES")||errString.equals("PRCUSUCCES"))
{
//System.out.println("status_date="+sdf.format(sysDateStr).toString());
try {
double ordQty=0;
Timestamp sysDate1 = null;
SimpleDateFormat sdf1 = null;
String sysDateStr1 = "",errString1="",loginEmpCode="";
double orderQty=0, convIndOrdQty=0;
double totalOrdqty=0 , indOrdQty=0;
DistCommon distCommon = new DistCommon();
int cnt = 0, detCnt = 0;
Calendar currentDate = Calendar.getInstance();
sdf1 = new SimpleDateFormat(
genericUtility.getApplDateFormat());
sysDateStr1 = sdf1.format(currentDate.getTime());
System.out
.println("after conf method Now the date is :=> "
+ sysDateStr1);
sysDate1 = Timestamp.valueOf(genericUtility
.getValidDateString(sysDateStr1,
genericUtility.getApplDateFormat(),
genericUtility.getDBDateFormat())
+ " 00:00:00.0");
String userId = genericUtility.getValueFromXTRA_PARAMS(
xtraParams, "loginCode");
loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
System.out.println("dlvQty@@At before"+dlvQty);
System.out.println("loginEmpCode@@"+loginEmpCode);
sql = " update poamd_hdr set confirmed = 'Y',conf_date = ?, emp_code__aprv = ? where amd_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1, sysDate1);
pstmt.setString(2, loginEmpCode);
pstmt.setString(3, tranIdPe);
cnt = pstmt.executeUpdate();
System.out.println("cnt@@update@"+cnt);
pstmt.close();
pstmt = null;
rs=null;
//rs.close();
if(errString.indexOf("Success")>-1 || errString.equalsIgnoreCase("PRCUSUCCES")||errString.equals("PRCUSUCCES")||errString.equals("PRCUSUCCES"))
{
if(indNo!=null || indNo.trim().length()>0) sql1 = "SELECT LINE_NO__ORD,IND_NO FROM POAMD_DET WHERE amd_no=? AND purc_order=? ";
{ pstmt1 = conn.prepareStatement(sql1);
sql = " select quantity from indent where ind_no = ? ";
pstmt1.setString(1, tranIdPe);
pstmt1.setString(2, purcOrder);
rs1 = pstmt1.executeQuery();
while (rs1.next()) {
lineNo1 = rs1.getString(1);
indNo = rs1.getString(2);
System.out.println("lineNo@@newhile" + lineNo1);
System.out.println("indNo@@newhile" + indNo);
if (indNo != null) {
System.out
.println("Comming after success msg@@");
/*
* Below code is used for one indent one porder
* case and also checking if receipt exist then
* set indent status should be closed'C'
*/
sql = " select quantity,ord_qty,quantity__stduom from indent where ind_no = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
rs = pstmt.executeQuery(); rs = pstmt.executeQuery();
if(rs.next()) if (rs.next()) {
{ indQty = rs.getDouble(1);
indQty=rs.getDouble(1); ordQty=rs.getDouble(2);
quantityStduom=rs.getDouble(3);
}
System.out.println("indQty@@"+indQty); orderQty=ordQty;
System.out.println("orderQty@@for dlvQty@@"+orderQty);
System.out.println("ordQty@@for NOT dlvQty@@"+ordQty);
System.out.println("indQty@@" + indQty);
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql = " select sum(quantity) from porddet where purc_order=? and line_no=? "; sql = " select d.quantity,d.dlv_qty ,d.unit,d.unit__std ,d.item_code from porder h,porddet d where h.purc_order=d.purc_order and d.purc_order=? and d.ind_no=? and d.line_no=? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, purcOrder); pstmt.setString(1, purcOrder);
pstmt.setString(2, lineNo); pstmt.setString(2, indNo);
rs= pstmt.executeQuery(); pstmt.setString(3, lineNo1);
if(rs.next()) rs = pstmt.executeQuery();
{ if (rs.next()) {
poDetTotalQty=rs.getDouble(1); poDetTotalQty = rs.getDouble(1);
dlvQty=rs.getDouble(2);
unit=rs.getString(3);
unitStd=rs.getString(4);
itemCode=rs.getString(5);
} }
System.out.println("poDetTotalQty@@" + poDetTotalQty);
System.out.println("dlvQty@@At before" + dlvQty);
System.out.println("dlvQty@@" + dlvQty);
System.out.println("unit@@" + unit);
System.out.println("unitStd@@" + unitStd);
System.out.println("itemCode@@" + itemCode);
System.out.println("poDetTotalQty@@"+poDetTotalQty);
rs.close(); rs.close();
rs = null; rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql = " select count(1) from porder a, porddet b "
+ "where a.purc_order = b.purc_order "
+ " and a.purc_order <> ? "
+ "and b.ind_no = ? and b.status='C' ";
/* + "and (case when a.status is null then 'O' else a.status end) = 'O' "
+ "and (case when b.status is null then 'O' else b.status end) = 'O'";*/
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder);
rs = pstmt.executeQuery();
if (rs.next()) {
cnt = rs.getInt(1);
}
System.out.println("cnt@@useless" + cnt);
rs.close();
rs = null;
pstmt.close();
pstmt = null;
/*
* total qty of purchase order detail is equal
* to indent quantity
*/
if(poDetTotalQty>=indQty) if(poDetTotalQty>=indQty)
{ {
System.out.println("comming into quantity>=indQty condition@@");
int updCnt=0;
sql = " update indent set status = 'L' where ind_no = ? ";
pstmt = conn.prepareStatement(sql);
if(dlvQty>0)
{
System.out.println("dlvQty@@At before" + dlvQty);
System.out.println("poDetTotalQty@@At before" + poDetTotalQty);
totalOrdqty = poDetTotalQty - dlvQty;
System.out.println("totalOrdqty@@[poqty-dlvqty:::]"+totalOrdqty);
convIndOrdQty=distCommon.convQtyFactor(unit, unitStd, itemCode, totalOrdqty, conn) ;
System.out.println("convIndOrdQty"+convIndOrdQty);
indOrdQty=orderQty+convIndOrdQty;
System.out.println("indOrdQty@@[orderQty+totalOrdqty]::"+indOrdQty);
//double totalOrdqty=indQty-dlvQty;
System.out.println("comming into dlvQty>0 condition@@");
int updCnt1=0;
if(indOrdQty==quantityStduom)
{
sql = " update indent set status = 'L',ord_qty="+indOrdQty+" where ind_no = ? ";
}else
{
sql = " update indent set status = 'O',ord_qty="+indOrdQty+" where ind_no = ? ";
}
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
updCnt = pstmt.executeUpdate(); updCnt1 = pstmt.executeUpdate();
System.out.println("Indent status updated@@"+updCnt); System.out.println("Indent status updated@@"+updCnt1);
//rs.close();
//rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql = " update porddet set status = 'O' where ind_no = ? and purc_order=? and line_no=? "; sql = " update porddet set status = 'O' where ind_no = ? and purc_order=? and line_no=? ";
...@@ -1255,26 +1397,48 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -1255,26 +1397,48 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder); pstmt.setString(2, purcOrder);
//lineNo1
pstmt.setString(3, lineNo1); pstmt.setString(3, lineNo1);
updCnt = pstmt.executeUpdate(); int updCnt = pstmt.executeUpdate();
System.out.println("porder status updated@@"+updCnt); System.out.println("porder status updated@@"+updCnt);
// rs.close();
//rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
if(dlvQty>0)
}else
{ {
System.out.println("dlvQty@@At before" + dlvQty);
System.out.println("poDetTotalQty@@At before" + poDetTotalQty);
totalOrdqty = poDetTotalQty - dlvQty;
System.out.println("totalOrdqty@@[poqty-dlvqty:::]"+totalOrdqty);
double totalOrdqty=indQty-dlvQty; convIndOrdQty=distCommon.convQtyFactor(unit, unitStd, itemCode, totalOrdqty, conn) ;
System.out.println("comming into dlvQty>0 condition@@"); System.out.println("convIndOrdQty"+convIndOrdQty);
int updCnt1=0;
sql = " update indent set status = 'O',ord_qty="+totalOrdqty+" where ind_no = ? ";
indOrdQty=orderQty+convIndOrdQty;
System.out.println("indOrdQty@@[orderQty+totalOrdqty]::"+indOrdQty);
System.out.println("comming into quantity>=indQty condition@@");
int updCnt=0;
if(indOrdQty==quantityStduom)
{
sql = " update indent set status = 'L',ord_qty="+indOrdQty+" where ind_no = ? ";
}
sql = " update indent set status = 'L' ,ord_qty="+indOrdQty+" where ind_no = ? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
updCnt1 = pstmt.executeUpdate(); updCnt = pstmt.executeUpdate();
System.out.println("Indent status updated@@"+updCnt1); System.out.println("Indent status updated@@"+updCnt);
//rs.close();
//rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql = " update porddet set status = 'O' where ind_no = ? and purc_order=? and line_no=? "; sql = " update porddet set status = 'O' where ind_no = ? and purc_order=? and line_no=? ";
...@@ -1282,20 +1446,37 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -1282,20 +1446,37 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder); pstmt.setString(2, purcOrder);
//lineNo1
pstmt.setString(3, lineNo1); pstmt.setString(3, lineNo1);
updCnt = pstmt.executeUpdate(); updCnt = pstmt.executeUpdate();
System.out.println("porder status updated@@"+updCnt); System.out.println("porder status updated@@"+updCnt);
// rs.close();
//rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
} }
}else if(poDetTotalQty<indQty) }else if(poDetTotalQty<indQty)
{ {
if(dlvQty>0)
{
System.out.println("dlvQty@@At before" + dlvQty);
System.out.println("poDetTotalQty@@At before" + poDetTotalQty);
totalOrdqty = poDetTotalQty - dlvQty;
System.out.println("totalOrdqty@@[poqty-dlvqty:::]"+totalOrdqty);
convIndOrdQty=distCommon.convQtyFactor(unit, unitStd, itemCode, totalOrdqty, conn) ;
System.out.println("convIndOrdQty"+convIndOrdQty);
indOrdQty=orderQty+convIndOrdQty;
System.out.println("indOrdQty@@[orderQty+totalOrdqty]::"+indOrdQty);
System.out.println("comming into quantity<indQty condition@@"); System.out.println("comming into quantity<indQty condition@@");
int updCnt=0; int updCnt=0;
...@@ -1312,26 +1493,45 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -1312,26 +1493,45 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
//dlv_qty-ord_qty //dlv_qty-ord_qty
sql = " update indent set status = 'O' where ind_no = ? ";
if(indOrdQty==quantityStduom)
{
sql = " update indent set status = 'L',ord_qty="+indOrdQty+" ,status_date=? where ind_no = ? ";
}else
{
sql = " update indent set status = 'O' ,ord_qty="+indOrdQty+" ,status_date=? where ind_no = ? ";
}
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setTimestamp(1, sysDate1);
pstmt.setString(2, indNo);
updCnt = pstmt.executeUpdate(); updCnt = pstmt.executeUpdate();
System.out.println("Indent status updated@@"+updCnt); System.out.println("Indent status updated@@"+updCnt);
// rs.close(); // rs.close();
// rs = null; // rs = null;
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
}else
}
if(dlvQty==0)
{ {
System.out.println("dlvQty@@At before" + dlvQty);
System.out.println("poDetTotalQty@@At before" + poDetTotalQty);
totalOrdqty = poDetTotalQty - dlvQty;
System.out.println("totalOrdqty@@[poqty-dlvqty:::]"+totalOrdqty);
convIndOrdQty=distCommon.convQtyFactor(unit, unitStd, itemCode, totalOrdqty, conn) ;
System.out.println("convIndOrdQty"+convIndOrdQty);
indOrdQty=orderQty+convIndOrdQty;
System.out.println("indOrdQty@@[orderQty+totalOrdqty]::"+indOrdQty);
System.out.println("comming into dlvQty==0 condition@@"); System.out.println("comming into dlvQty==0 condition@@");
int updCnt=0; int updCnt=0;
double ordQty=0.0; //double ordQty=0.0;
/*convIndOrdQty=distCommon.convQtyFactor(unit, unitStd, itemCode, indOrdQty, conn) ;
System.out.println("convIndOrdQty"+convIndOrdQty);
*/
sql = " update porddet set status = 'O' where ind_no = ? and purc_order=? and line_no=? "; sql = " update porddet set status = 'O' where ind_no = ? and purc_order=? and line_no=? ";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
pstmt.setString(2, purcOrder); pstmt.setString(2, purcOrder);
pstmt.setString(3, lineNo1); pstmt.setString(3, lineNo1);
...@@ -1339,24 +1539,18 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -1339,24 +1539,18 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
System.out.println("porder status updated@@"+updCnt); System.out.println("porder status updated@@"+updCnt);
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
//select ord_qty from indent where ind_no=?
sql = " select ord_qty from indent where ind_no=? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo);
rs= pstmt.executeQuery();
if(rs.next())
{
ordQty=rs.getDouble(1);
}
System.out.println("Indent status updated@@"+updCnt);
pstmt.close();
pstmt = null;
//ordQty=ordQty+quantity; //ordQty=ordQty+quantity;
if(indOrdQty==quantityStduom)
{
System.out
.println("dlvQty==0 condition@(orderQty==indQty)"+orderQty);
sql = " update indent set status = 'L',ord_qty="+indOrdQty+" where ind_no = ? ";
}else
{
System.out.println("updating poDetTotalQty condition@@"+poDetTotalQty); System.out.println("updating poDetTotalQty condition@@"+poDetTotalQty);
sql = " update indent set status = 'O' ,ord_qty="+poDetTotalQty+" where ind_no = ? "; sql = " update indent set status = 'O' ,ord_qty="+indOrdQty+" where ind_no = ? ";
}
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1, indNo); pstmt.setString(1, indNo);
...@@ -1365,19 +1559,66 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -1365,19 +1559,66 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
}
}
}
} }
//}
System.out.println("comming into new cof err condition@@"+errString);
return errString;
} }
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
try {
errString1 = itmDBAccessEJB.getErrorString(" ", "VMPOSUCC", userId);
return errString1;
return errString; } catch (Exception e) {
e.printStackTrace();
if(errString1==null)
{System.out.println("got errString exception"+e.getMessage());
conn.rollback();
conn.close();
} }
// TODO: handle exception
}finally
{
if(errString1!=null || errString1.trim().length()>0||errString1.indexOf("VMPOSUCC")>-1)
{
System.out.println("Connection commiting@dj");
conn.commit();
conn.close();
}
}
}
catch (Exception e) {
e.printStackTrace();
System.out.println("Exception after confirmed@@"+e.getMessage());
errString = e.getMessage();
throw new ITMException(e);
}
}else
{
System.out.println("ErrorString not null");
conn.rollback();
conn.close();
}
System.out.println("After confiremed error String-->"+errString); System.out.println("After confiremed error String-->"+errString);
return errString; return errString;
...@@ -1432,6 +1673,45 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -1432,6 +1673,45 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
return input; return input;
} }
/*public String getUserInfo()throws ITMException{
String xtraParams="";
StringBuffer userInfoStr = new StringBuffer();
String userId = "", loginEmpCode = "", loginSiteCode = "", entityCode = "", profileId = "",
userType = "", chgTerm = "";
try{
E12GenericUtility genericUtility = new E12GenericUtility();
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
loginEmpCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginEmpCode");
loginSiteCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginSiteCode");
entityCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"entityCode");
profileId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"profileId");
userType = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"userType");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"chgTerm");
System.out.println("xtraParams is @@@@@ " + xtraParams);
userInfoStr.append("<UserInfo>");
userInfoStr.append("<loginCode>").append("<![CDATA["+userId+"]]>").append("</loginCode>\r\n");
userInfoStr.append("<empCode>").append("<![CDATA["+loginEmpCode+"]]>").append("</empCode>\r\n");
userInfoStr.append("<siteCode>").append("<![CDATA["+loginSiteCode+"]]>").append("</siteCode>\r\n");
userInfoStr.append("<entityCode>").append("<![CDATA["+entityCode+"]]>").append("</entityCode>\r\n");
userInfoStr.append("<profileId>").append("<![CDATA["+profileId+"]]>").append("</profileId>\r\n");
userInfoStr.append("<userType>").append("<![CDATA["+userType+"]]>").append("</userType>\r\n");
userInfoStr.append("<remoteHost>").append("<![CDATA["+chgTerm+"]]>").append("</remoteHost>\r\n");
userInfoStr.append("</UserInfo>");
}
catch (Exception e){
throw new ITMException(e);
}
return userInfoStr.toString();
}
*/
private String saveData(String siteCode,String xmlString, Connection conn) throws ITMException private String saveData(String siteCode,String xmlString, Connection conn) throws ITMException
{ {
System.out.println("saving data..........."); System.out.println("saving data...........");
...@@ -1448,18 +1728,26 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord ...@@ -1448,18 +1728,26 @@ public class PorderOpenPrc extends ProcessEJB implements PorderOpenPrcLocal,Pord
authencate[0] = ""; authencate[0] = "";
authencate[1] = ""; authencate[1] = "";
System.out.println("xmlString to masterstateful [" + xmlString + "]"); System.out.println("xmlString to masterstateful [" + xmlString + "]");
//UserInfoBean userInfo = getUserInfo();
//String userInfo=getUserInfo();
//System.out.println("userInfo@at masterSate@"+userInfo.toString());
//retString = masterStateful.processRequest(userInfo, xmlString, true, conn);
// System.out.println("--retString - -" + retString);
retString = masterStateful.processRequest(authencate, siteCode, true, xmlString,true,conn); retString = masterStateful.processRequest(authencate, siteCode, true, xmlString,true,conn);
System.out.println("--retString - -"+retString); System.out.println("--retString - -"+retString);
} }
catch(ITMException itme) catch(ITMException itme)
{ {
System.out.println("ITMException :CreateDistOrder :saveData :==>"); System.out.println("ITMException :porderOpenPrc :saveData :==>");
throw itme; throw itme;
} }
catch(Exception e) catch(Exception e)
{ {
e.printStackTrace(); e.printStackTrace();
System.out.println("Exception :CreateDistOrder :saveData :==>"); System.out.println("Exception :porderOpenPrc :saveData :==>");
throw new ITMException(e); throw new ITMException(e);
} }
return retString; return retString;
......
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