Skip to content

B
business-java
Commit fd1ba6e4 authored by caluka's avatar caluka
Browse files
Options

Site Item Update Process screen process ejb 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@97581 ce508802-f39f-4f6c-b175-0d175dae99d5
parent ba541a6a
Show whitespace changes
Inline Side-by-side
Showing with 323 additions and 0 deletions
webitm-dis/ibase/webitm/ejb/dis/adv/SiteItemUpdatePrc.java 0 → 100755
View file @ fd1ba6e4
/********************************************************
Title : SiteItemUpdatePrc[D14ISUN010]
Date : 09/03/15
Developer: Chandrashekar
********************************************************/
package ibase.webitm.ejb.dis.adv;
import ibase.webitm.utility.*;
import ibase.webitm.ejb.*;
import ibase.system.config.*;
import java.rmi.RemoteException;
//import java.util.*;
import java.sql.*;
import org.w3c.dom.*;
//import java.text.SimpleDateFormat;
import javax.ejb.Stateless; // added for ejb3
@Stateless // added for ejb3
public class SiteItemUpdatePrc extends ProcessEJB implements SiteItemUpdatePrcLocal,SiteItemUpdatePrcRemote
{
String loginSiteCode = null;
GenericUtility genericUtility = GenericUtility.getInstance();
String currDateTs = null;
String chgUser = "";
String chgTerm = "";
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
public String process(String xmlString, String xmlString2, String windowName, String xtraParams)
throws RemoteException,ITMException
{
Document detailDom = null;
Document headerDom = null;
String retStr = "";
System.out.println("Process method called......");
try
{
if(xmlString != null && xmlString.trim().length()!=0)
{
headerDom = genericUtility.parseString(xmlString);
System.out.println("headerDom" + headerDom);
}
if(xmlString2 != null && xmlString2.trim().length()!=0)
{
detailDom = genericUtility.parseString(xmlString2);
System.out.println("detailDom" + detailDom);
}
retStr = process(headerDom, detailDom, windowName, xtraParams);
}
catch (Exception e)
{
System.out.println("Exception :SiteItemUpdatePrc :process(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
return retStr;
}//END OF PROCESS (1)
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException
{
Connection conn = null;
String resultString = "", errString = "";
boolean isError = false;
PreparedStatement pstmt = null;
PreparedStatement pstmt1 = null;
ResultSet rs = null;
ResultSet rs1 = null;
String sql1="";
String siteCode = "";
String finEntity = "";
String siteCodeFr="", siteCodeTo ="", itemCodeFr="",itemCodeTo = "",itemCode = "";
String siteCodeSupp = "", suppSour = "" ,itemSer = "",reoQty = "", integralQty = "";
int updCnt=0;
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
String userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"userId");
loginSiteCode = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginSiteCode");
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginCode");
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams,"termId");
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
conn.setAutoCommit(false);
finEntity = genericUtility.getColumnValue("fin_entity", headerDom);
siteCodeFr = genericUtility.getColumnValue("site_code__fr", headerDom);
siteCodeTo = genericUtility.getColumnValue("site_code__to", headerDom);
itemCodeFr = genericUtility.getColumnValue("item_code__fr", headerDom);
itemCodeTo = genericUtility.getColumnValue("item_code__to", headerDom);
integralQty = genericUtility.getColumnValue("integral_qty", headerDom);
reoQty = genericUtility.getColumnValue("reo_qty", headerDom);
itemSer = genericUtility.getColumnValue("item_ser", headerDom);
suppSour = genericUtility.getColumnValue("supp_sour", headerDom);
siteCodeSupp = genericUtility.getColumnValue("site_code__supp", headerDom);
System.out.println("siteCodeFr["+siteCodeFr+"]");
System.out.println("siteCodeTo["+siteCodeTo+"]");
System.out.println("itemCodeFr["+itemCodeFr+"]");
System.out.println("itemCodeTo["+itemCodeTo+"]");
System.out.println("integralQty["+integralQty+"]");
System.out.println("reoQty["+reoQty+"]");
System.out.println("itemSer["+itemSer+"]");
System.out.println("suppSour["+suppSour+"]");
System.out.println("siteCodeSupp["+siteCodeSupp+"]");
if(checkNull(integralQty).trim().length() == 0 && checkNull(reoQty).trim().length() == 0 && checkNull(itemSer).trim().length() == 0 &&
checkNull(suppSour).trim().length() == 0 && checkNull(siteCodeSupp).trim().length() == 0 )
{
resultString = itmDBAccessEJB.getErrorString("","PROCFAILED",userId);
return resultString;
}
sql1 = "select site_code,item_code from siteitem where site_code >= ? and site_code < = ? and item_code >= ? and item_code < = ?";
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, siteCodeFr);
pstmt1.setString(2, siteCodeTo);
pstmt1.setString(3, itemCodeFr);
pstmt1.setString(4, itemCodeTo);
rs1 = pstmt1.executeQuery();
while (rs1.next())
{
siteCode = rs1.getString( "site_code" ).trim();
itemCode = rs1.getString( "item_code" );
String sql="",subQuery="",finalSiteCodeSupp="";
sql = "update siteitem set ";
if(integralQty != null && integralQty.trim().length()>0 )
{
subQuery=" integral_qty='"+integralQty+"'";
sql = sql +subQuery;
}
if(reoQty != null)
{
if (subQuery.trim().length() == 0)
{
subQuery = " reo_qty='" + reoQty+"'";
sql = sql + subQuery;
} else
{
subQuery = " , reo_qty='" +reoQty+"'";
sql = sql + subQuery;
}
}
if(itemSer != null)
{
if (subQuery.trim().length() == 0)
{
subQuery = " item_ser='" + itemSer+"'";
sql = sql + subQuery;
} else
{
subQuery = " , item_ser='" + itemSer+"'";
sql = sql + subQuery;
}
}
if(suppSour != null)
{
if (subQuery.trim().length() == 0)
{
subQuery = " supp_sour='" + suppSour+"'";
sql = sql + subQuery;
} else
{
subQuery = " , supp_sour='" + suppSour+"'";
sql = sql + subQuery;
}
}
if(siteCodeSupp != null)
{
if (subQuery.trim().length() == 0)
{
if("P".equalsIgnoreCase(suppSour))
{
finalSiteCodeSupp = siteCodeSupp.trim()+siteCode.substring(2, siteCode.length());
System.out.println("finalSiteCodeSupp["+finalSiteCodeSupp+"]");
subQuery = " site_code__supp='" +finalSiteCodeSupp+"'";
sql = sql + subQuery;
}
else
{
subQuery = " site_code__supp='" + siteCodeSupp + "'";
sql = sql + subQuery;
}
} else
{
if("P".equalsIgnoreCase(suppSour))
{
finalSiteCodeSupp = siteCodeSupp.trim()+siteCode.substring(2, siteCode.length());
System.out.println("finalSiteCodeSupp>>>["+finalSiteCodeSupp+"]");
subQuery = " , site_code__supp='" + finalSiteCodeSupp+"'";
sql = sql + subQuery;
}
else
{
subQuery = " , site_code__supp='" + siteCodeSupp + "'";
sql = sql + subQuery;
}
}
}
sql = sql + " where site_code= ? and item_code = ?";
System.out.println("final sql>>>>"+sql);
pstmt = conn.prepareStatement( sql );
pstmt.setString(1,siteCode);
pstmt.setString(2,itemCode);
updCnt = pstmt.executeUpdate();
{
System.out.println("update count"+updCnt);
}
pstmt.close();
pstmt = null;
}
pstmt1.close();
pstmt1 = null;
rs1.close();
rs1 = null;
} // end of try code
catch(Exception e)
{
isError = true;
e.printStackTrace();
errString = e.getMessage();
throw new ITMException(e);
}
finally
{
try
{
if(rs != null)rs.close();
rs = null;
if(pstmt != null)pstmt.close();
pstmt = null;
if(conn != null)
{
if(isError)
{
conn.rollback();
System.out.println("connection rollback.............");
resultString = itmDBAccessEJB.getErrorString("","PROCFAILED",userId);
}
else
{
conn.commit();
System.out.println("commiting connection.............");
if(errString.equals(""))
{
errString = "PROCSUCC";
}
resultString = itmDBAccessEJB.getErrorString("",errString,userId);
}
if(conn != null)
{
conn.close();
conn = null;
}
}
}
catch(SQLException sqle)
{
sqle.printStackTrace();
}
}
System.out.println("returning from "+resultString);
return resultString;
} //end process
private String checkNull(String input)
{
if(input == null)
{
input = "";
}
return input;
}
}
\ No newline at end of file
webitm-dis/ibase/webitm/ejb/dis/adv/SiteItemUpdatePrcLocal.java 0 → 100755
View file @ fd1ba6e4
/********************************************************
Title : SiteItemUpdatePrcLocal[D14ISUN010]
Date : 09/03/15
Developer: Chandrashekar
********************************************************/
package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
//import javax.ejb.EJBObject;
import org.w3c.dom.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import javax.xml.parsers.*;
import ibase.webitm.ejb.ProcessLocal;
import javax.ejb.Local; // added for ejb3
import ibase.webitm.utility.ITMException;
@Local // added for ejb3`
public interface SiteItemUpdatePrcLocal extends ProcessLocal
{
public String process() throws RemoteException,ITMException;
public String process(String string1, String string2, String windowName, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
webitm-dis/ibase/webitm/ejb/dis/adv/SiteItemUpdatePrcRemote.java 0 → 100755
View file @ fd1ba6e4
/********************************************************
Title : SiteItemUpdatePrcRemote[D14ISUN010]
Date : 09/03/15
Developer: Chandrashekar
********************************************************/
package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
import javax.ejb.CreateException;
import javax.ejb.EJBHome;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.ProcessRemote;
import javax.ejb.Remote; // added for ejb3
import ibase.webitm.ejb.ValidatorRemote;// added for ejb3
@Remote // added for ejb3
public interface SiteItemUpdatePrcRemote extends ProcessRemote
{
public String process() throws RemoteException,ITMException;
public String process(String string1, String string2, String windowName, 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