Commit da4fa4b2 authored by mnair's avatar mnair

Added new component 1)StockTransferAct.java

                                      2)StockTransferActLocal.java
                                      3)StockTransferActRemote.java
                                                                             

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@180407 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 4505dd50
package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import javax.ejb.Stateless;
import org.w3c.dom.Document;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.utility.ITMException;
@Stateless
public class StockTransferAct extends ActionHandlerEJB implements StockTransferActLocal,StockTransferActRemote
{
E12GenericUtility genericUtility= new E12GenericUtility();
String act_type=null;
public String actionHandler() throws RemoteException,ITMException
{
return "";
}
public String actionHandler(String actionType, String xmlString, String xmlString1, String objContext, String xtraParams) throws RemoteException,ITMException
{
System.out.println(">>>>>>>>>>>>>In actionHandler actionDefault:");
Document dom = null;
Document dom1 = null;
String retString = null;
try
{
if(xmlString != null && xmlString.trim().length()!=0)
{
System.out.println(">>>>>>>>>>>>>XML String>:"+xmlString);
dom = genericUtility.parseString(xmlString);
System.out.println(">>>>>>>>>>>>>Dom:"+dom);
}
System.out.println(">>>>>>>>>>>>>>>>actionType:"+actionType+":");
if (actionType.equalsIgnoreCase("Default"))
{
if(xmlString1 != null && xmlString1.trim().length()!=0)
{
System.out.println(">>>>>>>>>>>>>>XML String1:"+xmlString1);
dom1 = genericUtility.parseString(xmlString1);
System.out.println(">>>>>>>>>>>>>>dom1:"+dom1);
}
System.out.println("*********************Before Call actionDefault*********************");
retString = actionDefault(dom1,objContext,xtraParams);//function to fetch data
}
}
catch(Exception e)
{
System.out.println("Exception :ModelHandler :actionHandler(String xmlString):" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
System.out.println("returning String from ModelHandler : actionHandler"+retString);
return retString;
}
private String actionDefault( Document dom1, String objContext, String xtraParams) throws RemoteException, ITMException
{
String refSerFor="",lineNo="",itemCode = "",itemDescr = "",locCodeFrom="",locCodeTo="",consOrder="";
String retString = null;
double quantity=0.0d;
int lineCntr=0;
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n");
Statement stmt = null;
ResultSet rs = null;
Connection conn = null;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
E12GenericUtility genericUtility= new E12GenericUtility();
try
{
conn = getConnection();
consOrder = genericUtility.getColumnValue("ref_id__for",dom1);
System.out.println("Consumer Order Reference id::::::::"+consOrder);
refSerFor = genericUtility.getColumnValue("ref_ser__for",dom1);
System.out.println("Consumer Order Reference series::::::::"+refSerFor);
String sql1=" SELECT CONSUME_ORD_DET.CONS_ORDER, "
+" CONSUME_ORD_DET.LINE_NO, "
+" CONSUME_ORD_DET.ITEM_CODE ,"
+" ITEM.DESCR,"
+" CONSUME_ORD_DET.QUANTITY,"
+" CONSUME_ORD_DET.LOC_CODE"
+" FROM CONSUME_ORD_DET,"
+" ITEM,"
+" CONSUME_ORD "
+" WHERE ( CONSUME_ORD_DET.ITEM_CODE = ITEM.ITEM_CODE ) "
+" and "
+"(CONSUME_ORD_DET.CONS_ORDER =CONSUME_ORD.CONS_ORDER ) "
+ " and "
+ "(( CONSUME_ORD_DET.CONS_ORDER='"+consOrder+"')) "
+" ORDER BY CONSUME_ORD_DET.LINE_NO ASC ";
stmt=conn.createStatement();
rs=stmt.executeQuery(sql1);
while(rs.next())
{
lineCntr++;
lineNo=rs.getString("line_no");
System.out.println("lineNO::"+lineNo);
consOrder=rs.getString("cons_order");
System.out.println("consOrder::"+consOrder);
itemCode = rs.getString("item_code");
System.out.println("itemCode"+itemCode);
itemDescr = rs.getString("descr");
System.out.println("itemDescr::"+itemDescr);
quantity=rs.getDouble("quantity");
System.out.println("quantity::"+quantity);
locCodeFrom = rs.getString("loc_code");
System.out.println("locCodeFrom::"+locCodeFrom);
locCodeTo = rs.getString("loc_code");
System.out.println("locCodeTo::"+locCodeTo);
System.out.println("Item no::::"+lineNo);
valueXmlString.append("<Detail>\r\n");
valueXmlString.append("<cons_order>").append("<![CDATA[").append(consOrder).append("]]>").append("</cons_order>\r\n");
valueXmlString.append("<line_no>").append("<![CDATA[").append(lineCntr).append("]]>").append("</line_no>\r\n");
valueXmlString.append("<item_code isSrvCallOnChg='0'>").append("<![CDATA[").append(itemCode.trim()).append("]]>").append("</item_code>\r\n");
valueXmlString.append("<item_descr>").append("<![CDATA[").append(itemDescr.trim()).append("]]>").append("</item_descr>\r\n");
valueXmlString.append("<quantity>").append("<![CDATA[").append(quantity).append("]]>").append("</quantity>\r\n");
valueXmlString.append("<loc_code__fr>").append("<![CDATA[").append(locCodeFrom.trim()).append("]]>").append("</loc_code__fr>\r\n");
valueXmlString.append("<loc_code__to>").append("<![CDATA[").append(locCodeTo.trim()).append("]]>").append("</loc_code__to>\r\n");
valueXmlString.append("</Detail>\r\n");
}//end of while loop
if(lineCntr==0)
{
retString = itmDBAccessEJB.getErrorString("","INVTR","","",conn);
}
System.out.println("*********In Act Default:"+lineCntr);
rs.close();
rs = null;
stmt.close();
stmt = null;
valueXmlString.append("</Root>\r\n");
}//end of try block
catch(Exception e)
{
System.out.println("Exception in actionDefault actionHandler :(Document dom)" +e.getMessage());
throw new ITMException(e);
}//end of catch block
finally
{
try
{
System.out.println("Closing Connection.....");
conn.close();
conn = null;
}
catch(Exception e){}
}//end of finally
return valueXmlString.toString();
}//end of actionDefault method
}
package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerLocal;
import javax.ejb.Local; // added for ejb3
@Local
public interface StockTransferActLocal extends ActionHandlerLocal
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString,String xmlString1, String objContext, String xtraParams) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ActionHandlerRemote;
import javax.ejb.Remote; // added for ejb3
@Remote // added for ejb3
public interface StockTransferActRemote extends ActionHandlerRemote
{
public String actionHandler() throws RemoteException,ITMException;
public String actionHandler(String actionType, String xmlString,String xmlString1, String objContext, String xtraParams) throws RemoteException,ITMException;
}
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