Skip to content

B
business-java
Commit cffbd54f authored by skale's avatar skale
Browse files
Options

Changes in code for working of random, all due and all items buttons in detail. 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@91190 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 1aaf0834
Hide whitespace changes
Inline Side-by-side
Showing with 283 additions and 166 deletions
webitm-dis/ibase/webitm/ejb/dis/adv/InvFreezeAct.java
View file @ cffbd54f
......@@ -11,19 +11,19 @@ import java.util.Random;
import java.sql.*;
import org.w3c.dom.*;
import javax.ejb.*;
import ibase.webitm.ejb.dis.DistCommon;
import ibase.webitm.ejb.sys.UtilMethods;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility;
import ibase.system.config.*;
import java.text.SimpleDateFormat;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal, InvFreezeActRemote
{
/*public void ejbCreate() throws RemoteException, CreateException
/* public void ejbCreate() throws RemoteException, CreateException
{
}
......@@ -37,14 +37,14 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
public void ejbPassivate()
{
}*/
public String actionHandler() throws RemoteException,ITMException
} */
Random rnd = new Random();
public String confirm() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException
public String confirm(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException
{
Document dom = null;
String resString = null;
......@@ -95,15 +95,16 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
{
String siteCode = "", locCodeFrom = "", locCodeTo = "";
String itemSerFrom = "", itemSerTo = "";
String sql = "", sql1 = "";
String sql = "";
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n");
Connection conn = null;
Statement stmt = null;
PreparedStatement pStmt1 = null;
PreparedStatement pStmt2 = null;
ResultSet rs = null, rs1 = null;
String errCode = "" ,errString = "", returnValue1 = "";
ConnDriver connDriver = new ConnDriver();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccess = new ITMDBAccessEJB();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
try
{
conn = connDriver.getConnectDB("DriverITM");
......@@ -117,28 +118,44 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
System.out.println("locCodeTo ="+locCodeTo);
System.out.println("ItemSerFrom ="+itemSerFrom);
System.out.println("ItemSerTo ="+itemSerTo);
sql = "SELECT A.ITEM_CODE,A.LOC_CODE,A.LOT_NO,A.LOT_SL,A.QUANTITY,A.UNIT FROM STOCK A,INVSTAT B "+
"WHERE A.SITE_CODE = '"+siteCode+ "' AND LOC_CODE >= '"+locCodeFrom + "' AND LOC_CODE <= '"+locCodeTo+ "' AND ITEM_SER >= '"+itemSerFrom+"' "+
"AND ITEM_SER <= '"+itemSerTo+ "' AND A.INV_STAT=B.INV_STAT AND B.AVAILABLE='Y' ";
sql = "SELECT A.ITEM_CODE,A.LOC_CODE,A.LOT_NO,A.LOT_SL,A.QUANTITY,A.UNIT "
+" FROM STOCK A,INVSTAT B "
+" WHERE A.SITE_CODE = ? "
+" AND LOC_CODE >= ? "
+" AND LOC_CODE <= ? "
+" AND ITEM_SER >= ? "
+" AND ITEM_SER <= ? "
+" AND A.INV_STAT=B.INV_STAT "
+" AND B.AVAILABLE='Y' ";
System.out.println("sql "+sql);
stmt = conn.createStatement();
rs = stmt.executeQuery(sql);
pStmt1 = conn.prepareStatement(sql);
pStmt1.setString( 1, siteCode );
pStmt1.setString( 2, locCodeFrom );
pStmt1.setString( 3, locCodeTo );
pStmt1.setString( 4, itemSerFrom );
pStmt1.setString( 5, itemSerTo );
rs = pStmt1.executeQuery();
while (rs.next())
{
String itemCode = rs.getString(1);
valueXmlString.append("<Detail>\r\n");
valueXmlString.append("<item_code>").append("<![CDATA[").append(rs.getString(1)).append("]]>").append("</item_code>\r\n");
sql1 = "SELECT DESCR FROM ITEM WHERE ITEM_CODE='" +rs.getString(1)+ "'";
rs1 = stmt.executeQuery(sql1);
valueXmlString.append("<site_code>").append("<![CDATA[").append(siteCode).append("]]>").append("</site_code>\r\n");
valueXmlString.append("<item_code>").append("<![CDATA[").append(itemCode).append("]]>").append("</item_code>\r\n");
sql = "SELECT DESCR FROM ITEM WHERE ITEM_CODE = ?";
pStmt2 = conn.prepareStatement(sql);
pStmt2.setString( 1, itemCode );
rs1 = pStmt2.executeQuery();
if(rs1.next())
{
returnValue1 = rs1.getString(1);
valueXmlString.append("<item_descr>").append(returnValue1).append("</item_descr>\r\n");
}
else
{
returnValue1="";
valueXmlString.append("<item_descr>").append(returnValue1).append("</item_descr>\r\n");
returnValue1 = rs1.getString(1);
}
pStmt2.close();
pStmt2 = null;
rs1.close();
rs1 = null;
valueXmlString.append("<item_descr>").append(returnValue1).append("</item_descr>\r\n");
valueXmlString.append("<loc_code>").append("<![CDATA[").append(rs.getString(2)).append("]]>").append("</loc_code>\r\n");
valueXmlString.append("<lot_no>").append("<![CDATA[").append(rs.getString(3)).append("]]>").append("</lot_no>\r\n");
valueXmlString.append("<lot_sl>").append("<![CDATA[").append(rs.getString(4)).append("]]>").append("</lot_sl>\r\n");
......@@ -146,7 +163,8 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
valueXmlString.append("<unit>").append("<![CDATA[").append(rs.getString(6)).append("]]>").append("</unit>\r\n");
valueXmlString.append("</Detail>\r\n");
}
stmt.close();
pStmt1.close();
pStmt1 = null;
valueXmlString.append("</Root>\r\n");
}
catch(SQLException e)
......@@ -180,20 +198,24 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
String itemSerFrom = "";
String itemSerTo = "";
String tranDate= "";
String sql = "", sql1 = "", sql2 = "";
String sql = "";
String returnValue1 = null;
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n");
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
Connection conn = null;
Statement stmt = null;
ResultSet rs = null, rs1 = null, rs2 = null;
PreparedStatement pStmt1 = null;
PreparedStatement pStmt2 = null;
ResultSet rs = null, rs2 = null;
String errCode = "" ,errString = "";
String detCnt = "0";
java.sql.Date phycDate = null;
java.sql.Date tempDate = null;
String cycleCount = null;
int cycleCnt = 0;
java.sql.Timestamp phycDate = null;
java.sql.Timestamp tranDateTs = null;
//java.util.Date tempDate = null;
ConnDriver connDriver = new ConnDriver();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccess = new ITMDBAccessEJB();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
UtilMethods utlMtds = new UtilMethods();
try
{
conn = connDriver.getConnectDB("DriverITM");
......@@ -203,55 +225,92 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
itemSerFrom = genericUtility.getColumnValue("item_ser__from",dom);
itemSerTo = genericUtility.getColumnValue("item_ser__to",dom);
tranDate = genericUtility.getColumnValue("tran_date",dom);
tranDateTs = Timestamp.valueOf(genericUtility.getValidDateString(tranDate, genericUtility.getApplDateFormat(), genericUtility.getDBDateFormat()) + " 00:00:00.0");
System.out.println("siteCode ="+siteCode);
System.out.println("locCodeFrom ="+locCodeFrom);
System.out.println("locCodeTo ="+locCodeTo);
System.out.println("ItemSerFrom ="+itemSerFrom);
System.out.println("ItemSerTo ="+itemSerTo);
System.out.println("TranDate="+tranDate);
System.out.println("tranDateTs="+tranDateTs);
sql = "SELECT A.ITEM_CODE,A.LOC_CODE,A.LOT_NO,A.LOT_SL,A.QUANTITY,A.UNIT,A.LAST_PHYC_DATE FROM STOCK A,INVSTAT B "+
"WHERE A.SITE_CODE ='"+siteCode+ "' AND LOC_CODE >=' "+locCodeFrom + "' AND LOC_CODE <= '"+locCodeTo+ "'AND ITEM_SER >='"+itemSerFrom+ "'"+
"AND ITEM_SER <='"+itemSerTo+ "'AND A.INV_STAT=B.INV_STAT AND B.AVAILABLE='Y'";
sql = "SELECT A.ITEM_CODE,A.LOC_CODE,A.LOT_NO,A.LOT_SL,A.QUANTITY,A.UNIT,A.LAST_PHYC_DATE "
+" FROM STOCK A,INVSTAT B "
+" WHERE A.SITE_CODE = ? "
+" AND LOC_CODE >= ? "
+" AND LOC_CODE <= ? "
+" AND ITEM_SER >= ? "
+" AND ITEM_SER <= ? "
+" AND A.INV_STAT=B.INV_STAT "
+" AND B.AVAILABLE='Y'";
System.out.println("sql "+sql);
stmt = conn.createStatement();
rs = stmt.executeQuery(sql);
pStmt1 = conn.prepareStatement(sql);
pStmt1.setString( 1, siteCode );
pStmt1.setString( 2, locCodeFrom );
pStmt1.setString( 3, locCodeTo );
pStmt1.setString( 4, itemSerFrom );
pStmt1.setString( 5, itemSerTo );
rs = pStmt1.executeQuery();
while (rs.next())
{
phycDate = rs.getDate("LAST_PHYC_DATE");
sql2 = "SELECT CYCLE_COUNT FROM ITEM WHERE ITEM_CODE = '"+rs.getString("ITEM_CODE")+"'";
rs2 = stmt.executeQuery(sql2);
if (rs2.next())
{
//phycDate.setDate(rs2.getInt("CYCLE_COUNT"));
phycDate = new java.sql.Date(phycDate.getTime()+(rs2.getInt("CYCLE_COUNT")* 60 * 60 * 1000));
}
tranDate = sdf.format(tranDate);
tempDate = java.sql.Date.valueOf(tranDate);
if (phycDate.before(tempDate))
String itemCode = rs.getString("ITEM_CODE");
phycDate = rs.getTimestamp("LAST_PHYC_DATE");
System.out.println("phycDate from rs.getDate is ==>"+phycDate);
if( phycDate != null )
{
valueXmlString.append("<Detail>\r\n");
valueXmlString.append("<item_code>").append("<![CDATA[").append(rs.getString(1)).append("]]>").append("</item_code>\r\n");
sql1 = "SELECT DESCR FROM ITEM WHERE ITEM_CODE='" +rs.getString(1)+ "'";
rs1 = stmt.executeQuery(sql1);
if(rs1.next())
sql = "SELECT CYCLE_COUNT FROM ITEM WHERE ITEM_CODE = ?";
pStmt2 = conn.prepareStatement(sql);
pStmt2.setString( 1, itemCode );
rs2 = pStmt2.executeQuery();
if (rs2.next())
{
returnValue1 = rs1.getString(1);
valueXmlString.append("<item_descr>").append(returnValue1).append("</item_descr>\r\n");
cycleCount = rs2.getString("CYCLE_COUNT");
cycleCnt = rs2.getInt("CYCLE_COUNT");
}
else
pStmt2.close();
pStmt2 = null;
rs2.close();
rs2 = null;
if( cycleCount != null && cycleCount.trim().length() > 0 )
{
returnValue1="";
valueXmlString.append("<item_descr>").append(returnValue1).append("</item_descr>\r\n");
phycDate = utlMtds.RelativeDate( phycDate, cycleCnt );
System.out.println("phycDate after calculation is ==>"+phycDate);
if( phycDate.compareTo(tranDateTs) <= 0 )
{
valueXmlString.append("<Detail>\r\n");
valueXmlString.append("<site_code>").append("<![CDATA[").append(siteCode).append("]]>").append("</site_code>\r\n");
valueXmlString.append("<item_code>").append("<![CDATA[").append(itemCode).append("]]>").append("</item_code>\r\n");
sql = "SELECT DESCR FROM ITEM WHERE ITEM_CODE= ?";
pStmt2 = conn.prepareStatement(sql);
pStmt2.setString( 1, itemCode );
rs2 = pStmt2.executeQuery();
if(rs2.next())
{
returnValue1 = rs2.getString(1);
}
pStmt2.close();
pStmt2 = null;
rs2.close();
rs2 = null;
valueXmlString.append("<item_descr>").append(returnValue1).append("</item_descr>\r\n");
valueXmlString.append("<loc_code>").append("<![CDATA[").append(rs.getString(2)).append("]]>").append("</loc_code>\r\n");
valueXmlString.append("<lot_no>").append("<![CDATA[").append(rs.getString(3)).append("]]>").append("</lot_no>\r\n");
valueXmlString.append("<lot_sl>").append("<![CDATA[").append(rs.getString(4)).append("]]>").append("</lot_sl>\r\n");
valueXmlString.append("<quantity>").append("<![CDATA[").append(rs.getString(5)).append("]]>").append("</quantity>\r\n");
valueXmlString.append("<unit>").append("<![CDATA[").append(rs.getString(6)).append("]]>").append("</unit>\r\n");
valueXmlString.append("</Detail>\r\n");
}
}
valueXmlString.append("<loc_code>").append("<![CDATA[").append(rs.getString(2)).append("]]>").append("</loc_code>\r\n");
valueXmlString.append("<lot_no>").append("<![CDATA[").append(rs.getString(3)).append("]]>").append("</lot_no>\r\n");
valueXmlString.append("<lot_sl>").append("<![CDATA[").append(rs.getString(4)).append("]]>").append("</lot_sl>\r\n");
valueXmlString.append("<quantity>").append("<![CDATA[").append(rs.getString(5)).append("]]>").append("</quantity>\r\n");
valueXmlString.append("<unit>").append("<![CDATA[").append(rs.getString(6)).append("]]>").append("</unit>\r\n");
valueXmlString.append("</Detail>\r\n");
}
}
}
pStmt1.close();
pStmt1 = null;
rs.close();
rs = null;
valueXmlString.append("</Root>\r\n");
}
catch(SQLException e)
......@@ -291,6 +350,7 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
String returnValue1 = "", returnValue2 = "";
String errCode = "" ,errString = "";
String detCnt = "0",varValue="";
PreparedStatement pStmt1 = null;
boolean bool=false;
double retries=0;
int xx,zz,cnt=0, rowId = 0, ItmCount = 0, maxItems=400;
......@@ -298,12 +358,12 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
ArrayList site= new ArrayList();
ConnDriver connDriver = new ConnDriver();
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccess = new ITMDBAccessEJB();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
DistCommon dstCmn = new DistCommon();
try
{
Random rnd = new Random();
conn = connDriver.getConnectDB("DriverITM");
stmt1= conn.createStatement();
//stmt1= conn.createStatement();
tranId= genericUtility.getColumnValue("tran_id",dom);
System.out.println("tranId :"+tranId);
lineNo= genericUtility.getColumnValue("line_no",dom);
......@@ -323,115 +383,60 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
if (status.equals("F") || status.equals("U") || status.equals("V"))
{
errCode = "";
errString = itmDBAccess.getErrorString("",errCode,"","",conn);
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn);
System.out.println("errString :"+errString);
return errString;
}
sql1="SELECT VAR_VALUE,VAR_VALUE FROM DISPARM WHERE VAR_NAME= 'PHYCNTITEMS' AND PRD_CODE = '999999'";
System.out.println(sql1);
rs1 = stmt1.executeQuery(sql1);
if(rs1.next())
varValue = dstCmn.getDisparams("999999", "PHYCNTITEMS", conn);
System.out.println("varValue :"+varValue);
if( varValue != null && varValue.trim().length() > 0 )
{
maxItems = rs1.getInt(1);
maxItems = Integer.parseInt(varValue);
System.out.println("maxItems :"+maxItems);
varValue = rs1.getString(2);
System.out.println("varValue :"+varValue);
}
if (varValue == null || varValue.equals("0"))
{
varValue = "0";
maxItems= 10;
}
sql2="SELECT SITEITEM.SITE_CODE,SITEITEM.ITEM_CODE,ITEM.ITEM_SER FROM SITEITEM,ITEM "
+"WHERE SITEITEM.ITEM_CODE = ITEM.ITEM_CODE AND SITEITEM.SITE_CODE ='"+siteCode+"' "
+"AND ITEM.ITEM_SER >='"+ItemSerFrom+"' AND ITEM.ITEM_SER <='"+ItemSerTo+"' "
+"AND ITEM.STK_OPT IN ('1','2')";
System.out.println("sql2="+sql2);
sql1 = "SELECT SITEITEM.SITE_CODE,SITEITEM.ITEM_CODE,ITEM.ITEM_SER FROM SITEITEM,ITEM "
+" WHERE SITEITEM.ITEM_CODE = ITEM.ITEM_CODE "
+" AND SITEITEM.SITE_CODE ='"+siteCode+"' "
+" AND ITEM.ITEM_SER >='"+ItemSerFrom+"' "
+" AND ITEM.ITEM_SER <='"+ItemSerTo+"' "
+" AND ITEM.STK_OPT IN ('1','2')";
System.out.println("sql1="+sql1);
stmt2= conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
rs2=stmt2.executeQuery(sql2);
rs2=stmt2.executeQuery(sql1);
int noOfRows = 0;
while(rs2.next())
{
noOfRows++;
}
System.out.println("noOfRows :"+noOfRows);
//System.out.println("noOfRows :"+noOfRows);
noOfRows = noOfRows + 1;
System.out.println("noOfRows + 1 :"+noOfRows);
for (xx = 1; xx <= maxItems; xx++)
{
retries++;
rowId = rnd.nextInt(noOfRows);
System.out.println("rowId :"+rowId);
System.out.println("noOfRows :"+noOfRows);
//if(noOfRows == 1)
if(rowId < noOfRows)// by using 21 it was ok.
{
System.out.println("rowId :"+rowId);
if (rowId == 0)
{
System.out.println("rowId :"+rowId);
rowId = 1;
System.out.println("rowId :"+rowId);
}
System.out.println("rowId :"+rowId);
rs2.absolute(rowId);
//if(rs2.next())
//{
itemCode = rs2.getString(2);
System.out.println("itemCode :"+itemCode);
//}
boolean itemSelected = false;
System.out.println("site.size() :"+site.size());
for (zz = 0; zz < site.size(); zz++)
{
System.out.println("site.size() :"+site.size());
System.out.println("site.get(zz)=="+site.get(zz));
if (site.get(zz).toString().equalsIgnoreCase(itemCode))
{
System.out.println("ItemCode found and flag set to true");
itemSelected = true;
cnt=0;
}
}//for
if (!itemSelected)
{
sql3 = "SELECT COUNT(*) FROM STOCK S,INVSTAT ISTAT "
+"WHERE S.ITEM_CODE= '"+itemCode+"' AND S.SITE_CODE='"+siteCode+"' "
+"AND S.LOC_CODE>= '"+locCodeFrom+"' AND S.LOC_CODE<='"+locCodeTo+"' "
+"AND S.INV_STAT = ISTAT.INV_STAT AND ISTAT.AVAILABLE ='Y'";
System.out.println("sql3 :"+sql3);
rs1 = stmt1.executeQuery(sql3);
if (rs1.next())
{
cnt = rs1.getInt(1);
System.out.println("cnt :"+cnt);
}
}
if (cnt >= 1)
{
site.add(itemCode);
}
else
{
if (retries > 4)
{
site.add("");
}
else
{
continue;
}
}// else end
}
//retries++;
//System.out.println("Calling getCount function ==>"+retries);
getCount( retries, rs2, siteCode, locCodeFrom, locCodeTo, site, noOfRows, conn );
retries = 0;
}//end for
stmt2.close();
rs2.close();
xx = site.size();
System.out.println("Size of ArrayList XX:"+xx);
if (xx == 0)
{
errCode = "VTDETCNT";
errString = itmDBAccess.getErrorString("",errCode,"","",conn);
errString = itmDBAccessEJB.getErrorString("",errCode,"","",conn);
System.out.println("errString :"+errString);
return errString;
}
......@@ -463,14 +468,23 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
valueXmlString.append("<Detail>\r\n");
valueXmlString.append("<tran_id>").append("<![CDATA[").append(tranId).append("]]>").append("</tran_id>\r\n");
valueXmlString.append("<site_code>").append("<![CDATA[").append(siteCode).append("]]>").append("</site_code>\r\n");
sql5 = "SELECT DESCR FROM ITEM WHERE ITEM_CODE='" +itemCode+ "'";
sql5 = "SELECT DESCR FROM ITEM WHERE ITEM_CODE= ?";
System.out.println("sql5 :"+sql5);
rs5 = stmt1.executeQuery(sql5);
pStmt1 = conn.prepareStatement(sql5);
pStmt1.setString( 1, itemCode );
rs5 = pStmt1.executeQuery();
//rs5 = stmt1.executeQuery(sql5);
if(rs5.next())
{
returnValue1 = rs5.getString(1);
System.out.println("returnValue1 :"+returnValue1);
}
pStmt1.close();
pStmt1 = null;
rs5.close();
rs5 = null;
valueXmlString.append("<site_descr>").append(returnValue1).append("</site_descr>\r\n");
valueXmlString.append("<quantity>").append("<![CDATA[").append(rs4.getDouble(2)).append("]]>").append("</quantity>\r\n");
valueXmlString.append("<lot_no>").append("<![CDATA[").append(rs4.getString(3)).append("]]>").append("</lot_no>\r\n");
......@@ -478,19 +492,32 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
valueXmlString.append("<item_ser>").append("<![CDATA[").append(rs4.getString(5)).append("]]>").append("</item_ser>\r\n");
valueXmlString.append("<loc_code>").append("<![CDATA[").append(rs4.getString(6)).append("]]>").append("</loc_code>\r\n");
valueXmlString.append("<item_code>").append("<![CDATA[").append(itemCode).append("]]>").append("</item_code>\r\n");
sql6 = "SELECT DESCR FROM ITEM WHERE SITE_CODE='" +siteCode+ "'";
System.out.println("sql6 :"+sql6);
rs6 = stmt1.executeQuery(sql6);
sql6 = "SELECT DESCR FROM SITE WHERE SITE_CODE= ?";
System.out.println("sql6 :"+sql6);
pStmt1 = conn.prepareStatement(sql6);
pStmt1.setString( 1, siteCode );
rs6 = pStmt1.executeQuery();
//rs6 = stmt1.executeQuery(sql6);
if(rs6.next() )
{
returnValue2 = rs6.getString(1);
}
//stmt1.close();
pStmt1.close();
pStmt1 = null;
rs6.close();
rs6 = null;
valueXmlString.append("<item_descr>").append(returnValue2).append("</item_descr>\r\n");
valueXmlString.append("<unit>").append("<![CDATA[").append(rs4.getString(8)).append("]]>").append("</unit>\r\n");
valueXmlString.append("</Detail>\r\n");
}
stmt4.close();
rs4.close();
rs4 = null;
}//for
stmt4.close();
valueXmlString.append("</Root>\r\n");
}//try
catch(SQLException e)
......@@ -515,4 +542,91 @@ public class InvFreezeAct extends ActionHandlerEJB implements InvFreezeActLocal,
System.out.println("valueXmlString.toString() :"+valueXmlString.toString());
return valueXmlString.toString();
}
private void getCount( double retries, ResultSet rs2, String siteCode, String locCodeFrom, String locCodeTo, ArrayList site, int noOfRows, Connection conn ) throws RemoteException , ITMException
{
String itemCode = "";
String sql = "";
int cnt = 0;
ResultSet rs1 = null;
PreparedStatement pStmt1 = null;
try
{
retries++;
//System.out.println("retries inside function ==>"+retries);
int rowId = rnd.nextInt(noOfRows);
//System.out.println("rowId ==>"+rowId);
if (rowId == 0)
{
rowId = 1;
}
rs2.absolute(rowId);
itemCode = rs2.getString(2);
//System.out.println("itemCode ==>"+itemCode);
boolean itemSelected = false;
for (int zz = 0; zz < site.size(); zz++)
{
if (site.get(zz).toString().equalsIgnoreCase(itemCode))
{
itemSelected = true;
cnt = 0;
}
}
//System.out.println("itemSelected ==>"+itemSelected);
if (!itemSelected)
{
sql = "SELECT COUNT(*) FROM STOCK S,INVSTAT ISTAT "
+"WHERE S.ITEM_CODE= ? AND S.SITE_CODE= ? "
+"AND S.LOC_CODE>= ? AND S.LOC_CODE<= ? "
+"AND S.INV_STAT = ISTAT.INV_STAT AND ISTAT.AVAILABLE ='Y'";
pStmt1 = conn.prepareStatement(sql);
pStmt1.setString( 1, itemCode );
pStmt1.setString( 2, siteCode );
pStmt1.setString( 3, locCodeFrom );
pStmt1.setString( 4, locCodeTo );
rs1 = pStmt1.executeQuery();
if (rs1.next())
{
cnt = rs1.getInt(1);
System.out.println("cnt :"+cnt);
}
pStmt1.close();
pStmt1 = null;
rs1.close();
rs1 = null;
}
//System.out.println("cnt ==>"+cnt);
if (cnt >= 1)
{
site.add(itemCode);
}
else
{
//System.out.println("Inside else");
if (retries > 4)
{
//System.out.println("Inside retries > 4");
site.add("");
}
else
{
//retries++;
//System.out.println("Calling getCount from same function");
getCount( retries, rs2, siteCode, locCodeFrom, locCodeTo, site, noOfRows, conn );
//System.out.println("After getCount from same function");
}
}
/* for( int a = 0; a < site.size(); a++ )
{
System.out.println("Total Site array is ==>"+(String)site.get(a));
} */
}
catch(Exception e )
{
System.out.println("Exception : InvFreeze : actionHandler :(Document dom)" +e.getMessage());
throw new ITMException(e);
}
}
}
\ No newline at end of file
webitm-dis/ibase/webitm/ejb/dis/adv/InvFreezeActLocal.java
View file @ cffbd54f
package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
//import javax.ejb.CreateException;
//import javax.ejb.EJBHome;
//import ibase.webitm.ejb.ActionHandlerHome;
//import ibase.webitm.ejb.ActionHandler;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local // added for ejb3
public interface InvFreezeActLocal extends ActionHandlerLocal//,EJBObject
public interface InvFreezeActLocal extends ActionHandlerLocal
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException;
//public ActionHandler create() throws RemoteException, CreateException;
public String confirm() throws RemoteException,ITMException;
public String confirm(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
webitm-dis/ibase/webitm/ejb/dis/adv/InvFreezeActRemote.java
View file @ cffbd54f
......@@ -3,14 +3,14 @@ package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import ibase.webitm.utility.ITMException;
//import ibase.webitm.ejb.ActionHandler;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface InvFreezeActRemote extends ActionHandlerRemote//,EJBObject
@Remote
public interface InvFreezeActRemote extends ActionHandlerRemote
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException;
public String confirm() throws RemoteException,ITMException;
public String confirm(String actionType, String xmlString, String objContext, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
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