Skip to content

B
business-java
Commit eeca80de authored by mjadhav's avatar mjadhav
Browse files
Options

changes done by manoj 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@94984 ce508802-f39f-4f6c-b175-0d175dae99d5
parent b1277af4
Show whitespace changes
Inline Side-by-side
Showing with 383 additions and 1 deletion
webitm-dis/ibase/webitm/ejb/dis/IncHoldRelGenIC.java
View file @ eeca80de
......@@ -4,6 +4,7 @@ purpose : set default value in inv hold process */
package ibase.webitm.ejb.dis;
import ibase.system.config.ConnDriver;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
......@@ -17,9 +18,12 @@ import java.util.*;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
@Stateless // added for ejb3
public class IncHoldRelGenIC extends ValidatorEJB implements IncHoldRelGenICLocal,IncHoldRelGenICRemote
{
GenericUtility genericUtility = GenericUtility.getInstance();
public String itemChanged(String xmlString,String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
System.out.println("@@@@@@@ default itemChanged called");
......@@ -57,11 +61,14 @@ public class IncHoldRelGenIC extends ValidatorEJB implements IncHoldRelGenICLoca
int currentFormNo =0;
int childNodeListLength = 0;
int ctr=0;
DistCommon distcommon=null;
String relAutoConfirm="";
try
{
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver=null;
distcommon=new DistCommon();
if(objContext != null && objContext.trim().length()>0)
{
currentFormNo = Integer.parseInt(objContext.trim());
......@@ -92,13 +99,26 @@ public class IncHoldRelGenIC extends ValidatorEJB implements IncHoldRelGenICLoca
String sysDate = sdf.format(currentDate.getTime());
System.out.println("Now the date is :=> " + sysDate);
relAutoConfirm = distcommon.getDisparams("999999","REL_AUTO_CONF", conn);//Manoj dtd 15/04/2014 Set Auto_confirmed from disparm
if (relAutoConfirm == null|| "NULLFOUND".equalsIgnoreCase(relAutoConfirm))
{
relAutoConfirm = "N";
}
valueXmlString.append( "<tran_id__from><![CDATA[" ).append( "00").append( "]]></tran_id__from>\r\n" );
valueXmlString.append( "<tran_id__to><![CDATA[" ).append("ZZ").append( "]]></tran_id__to>\r\n" );
valueXmlString.append( "<ref_id__from><![CDATA[" ).append( "00").append( "]]></ref_id__from>\r\n" );
valueXmlString.append( "<ref_id__to><![CDATA[" ).append("ZZ").append( "]]></ref_id__to>\r\n" );
valueXmlString.append( "<lock_code__from><![CDATA[" ).append( "00").append( "]]></lock_code__from>\r\n" );
valueXmlString.append( "<lock_code__to><![CDATA[" ).append("ZZ").append( "]]></lock_code__to>\r\n" );
valueXmlString.append( "<auto_confirmed><![CDATA[" ).append("Y").append( "]]></auto_confirmed>\r\n" );
valueXmlString.append( "<lot_no__from><![CDATA[" ).append( "00").append( "]]></lot_no__from>\r\n" );//Added by Manoj dtd 15/04/2014 to set default value
valueXmlString.append( "<lot_no__to><![CDATA[" ).append("ZZ").append( "]]></lot_no__to>\r\n" );//Added by Manoj dtd 15/04/2014 to set default value
valueXmlString.append( "<auto_confirmed><![CDATA[" ).append(relAutoConfirm).append( "]]></auto_confirmed>\r\n" );
}
......@@ -139,6 +159,368 @@ public class IncHoldRelGenIC extends ValidatorEJB implements IncHoldRelGenICLoca
}
return valueXmlString.toString();
}
public String wfValData(String xmlString, String xmlString1,String xmlString2, String objContext, String editFlag, String xtraParams) throws RemoteException, ITMException
{
System.out.println("@@@@@@@ Validation called");
Document dom = null;
Document dom1 = null;
Document dom2 = null;
String errString = "";
try
{
dom = parseString(xmlString);
dom1 = parseString(xmlString1);
dom2 = parseString(xmlString2);
System.out.println("xmlString--------"+xmlString);
System.out.println("xmlString1--------"+xmlString1);
System.out.println("xmlString2--------"+xmlString2);
errString = wfValData(dom,dom1,dom2,objContext,editFlag,xtraParams);
}
catch(Exception e)
{
System.out.println("Exception : [TrainingEJB][itemChanged(String,String)] :==>\n"+e.getMessage());
}
return errString;
}
public String wfValData(Document dom, Document dom1,Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException
{
String errString="";
String tranIdFrom="",tranIdTo="",schRelDateFromstr="", schRelDateTostr="",refIdFrom="",refIdTo="",lockCodeFrom="",lockCodeTo="",lotNoFrom="",lotNoTo="";
Timestamp schRelDateFrom=null,schRelDateTo=null;
String errCode = "";
String errorType = "";
ArrayList<String> errList = new ArrayList();
ArrayList<String> errFields = new ArrayList<String>();StringBuffer errStringXml = new StringBuffer("<?xml version = \"1.0\"?> \r\n <Root> <Errors>");
int count = 0;
String userId="";
ConnDriver connDriver = new ConnDriver();
Connection conn = null;
PreparedStatement pstmt = null,pstmt1=null ;
ResultSet rs = null,rs1=null;
String getDataSql="";
int i=7;
String unconfInvHolddet="",unconfInvReldet="";
String confirmed="";
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
String invHoldId="";
String invHoldLine="";
try
{
conn = connDriver.getConnectDB("DriverITM");
userId = getValueFromXTRA_PARAMS(xtraParams, "loginCode");
tranIdFrom = genericUtility.getColumnValue("tran_id__from",dom);
tranIdTo = genericUtility.getColumnValue("tran_id__to",dom);
schRelDateFromstr = genericUtility.getColumnValue("sch_rel_date__from",dom);
schRelDateTostr = genericUtility.getColumnValue("sch_rel_date__to",dom);
refIdFrom = genericUtility.getColumnValue("ref_id__from",dom);
refIdTo = genericUtility.getColumnValue("ref_id__to",dom);
lockCodeFrom = genericUtility.getColumnValue("lock_code__from",dom);
lockCodeTo = genericUtility.getColumnValue("lock_code__to",dom);
lotNoFrom = genericUtility.getColumnValue("lot_no__from",dom);
lotNoTo = genericUtility.getColumnValue("lot_no__to",dom);
System.out.println("schRelDateFromstr : ["+schRelDateFromstr+"]:::schRelDateTostr:["+schRelDateTostr+"]");
if(schRelDateFromstr != null)
{
System.out.println("schRelDateFromstr : ["+schRelDateFromstr);
schRelDateFrom= Timestamp.valueOf(genericUtility.getValidDateString(schRelDateFromstr, genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()) + " 00:00:00.0");
}
if(schRelDateTostr != null)
{
System.out.println(" :::schRelDateTostr:["+schRelDateTostr+"]");
//schRelDateTo= Timestamp.valueOf(genericUtility.getValidDateString(schRelDateTostr, genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()) + " 00:00:00.0");//Commented by Manoj dtd 04/10/2013 to set hrs and minutes also
schRelDateTo= Timestamp.valueOf(genericUtility.getValidDateString(schRelDateTostr, genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat()) + " 23:59:59.0");
}
System.out.println("schRelDateFrom : ["+schRelDateFrom+"]:::schRelDateTo:["+schRelDateTo+"]");
System.out.println("tranIdFrom=>"+tranIdFrom);
System.out.println("tranIdTo=>"+tranIdTo);
System.out.println("refIdFrom =>"+refIdFrom);
System.out.println("refIdTo =>"+refIdTo);
System.out.println("lockCodeFrom=>"+lockCodeFrom);
System.out.println("lockCodeTo=>"+lockCodeTo);
System.out.println("lotNoFrom=>"+lotNoFrom);
System.out.println("lotNoTo=>"+lotNoTo);
if ( tranIdFrom == null || tranIdFrom.trim().length() == 0 )
{
System.out.println("tran id from is Null...");
errCode = "VMTRIDFRNU";
errList.add(errCode);
errFields.add("tran_id__from");
}
if ( tranIdTo == null || tranIdTo.trim().length() == 0 )
{
System.out.println("tran id to is Null...");
errCode = "VMTRIDTONU";
errList.add(errCode);
errFields.add("tran_id__to");
}
if ( schRelDateFrom == null )
{
System.out.println("schedule release date from is Null...");
errCode = "VMSCDTFRNU";
errList.add(errCode);
errFields.add("sch_rel_date__from");
}
else
{
if(schRelDateTo != null)
{
if(schRelDateFrom.after(schRelDateTo))
{
errCode = "SCDTTOINV";
errList.add(errCode);
errFields.add("sch_rel_date__to");
}
}
}
if ( schRelDateTo == null )
{
System.out.println("schedule release date to is Null...");
errCode = "VMSCDTTONU";
errList.add(errCode);
errFields.add("sch_rel_date__to");
}
else
{
if(schRelDateTo != null)
{
if(schRelDateTo.before(schRelDateFrom))
{
errCode = "SCDTTOINV";
errList.add(errCode);
errFields.add("sch_rel_date__to");
}
}
}
if ( lotNoFrom == null || lotNoFrom.trim().length() == 0 )
{
System.out.println("lotNoFrom is Null...");
errCode = "VMINVLTFR";
errList.add(errCode);
errFields.add("lot_no__from");
}
if ( lotNoTo == null || lotNoTo.trim().length() == 0 )
{
System.out.println("lotNoTo is Null...");
errCode = "VMINVLTTO";
errList.add(errCode);
errFields.add("lot_no__from");
}
System.out.println("refIdFrom["+refIdFrom+"]:::::::refIdTo["+refIdTo+"]");
//ih.lock_code ,ihd.lot_no,ihd.lot_sl,ihd.remarks ADDED BY RITESH
getDataSql= " select ihd.tran_id,ihd.line_no,ihd.lot_no,ihd.lot_sl," +
" case when ihd.hold_status is null then 'H' else ihd.hold_status end as hold_status ," +
" ihd.item_code,ihd.loc_code,ihd.site_code,ih.confirmed " +
" from inv_hold_det ihd,inv_hold ih where ( ihd.tran_id = ih.tran_id )" +
" and ( ihd.tran_id >= ? and ihd.tran_id <= ? ) and ( ih.lock_code >= ? and ih.lock_code <= ? )" +
" and ( ihd.sch_rel_date between ? and ? ) and ihd.hold_status <> 'R' "
+" and ( ihd.lot_no >= '"+lotNoFrom+"' and ihd.lot_no <= '"+lotNoTo+"' ) ";
//and ( ihd.lock_code between ? and ? )
if(refIdFrom != null )
{
getDataSql = getDataSql + " and ( ih.ref_id >= ? or ih.ref_id is null ) ";
}
if(refIdTo != null )
{
getDataSql = getDataSql + " and ( ih.ref_id <= ? or ih.ref_id is null ) ";
}
System.out.println("Sql Fired :::::"+getDataSql.trim().length());
if (getDataSql.trim().length()>0)
{
System.out.println("Sql Fired :::::"+getDataSql);
pstmt = conn.prepareStatement(getDataSql);
pstmt.setString(1,tranIdFrom);
pstmt.setString(2,tranIdTo);
pstmt.setString(3,lockCodeFrom); //added by Ritesh on 08/05/13
pstmt.setString(4,lockCodeTo); //added by Ritesh on 08/05/13
pstmt.setTimestamp(5,schRelDateFrom);
pstmt.setTimestamp(6,schRelDateTo);
if(refIdFrom != null )
{
pstmt.setString(i,refIdFrom);
i++;
}
if( refIdTo != null)
{
pstmt.setString(i,refIdTo);
}
System.out.println("QUERY IS IN PROCESS..........");
rs = pstmt.executeQuery();
System.out.println("QUERY PROCESS FINISED.......");
while(rs.next())
{
confirmed=rs.getString("confirmed")==null?"N":rs.getString("confirmed");
if("N".equalsIgnoreCase(confirmed))
{
unconfInvHolddet+=rs.getString("lot_no")+",";
}
else
{
invHoldId=rs.getString("tran_id");
invHoldLine=rs.getString("line_no");
pstmt1=conn.prepareStatement("select count(1) from inv_hold_rel where tran_id in( select tran_id from inv_hold_rel_det where tran_id__hold=? and line_no__hold=?) and confirmed='N' ");
pstmt1.setString(1,invHoldId);
pstmt1.setString(2,invHoldLine);
rs1=pstmt1.executeQuery();
if(rs1.next())
{
if(rs1.getDouble(1)>0)
{
unconfInvReldet+=rs.getString("lot_no")+",";
}
}
rs1.close();
rs1=null;
pstmt1.close();
pstmt1=null;
}
}
rs.close();
rs=null;
pstmt.close();
pstmt=null;
System.out.println("unconfInvHolddet-------"+unconfInvHolddet);
if(unconfInvHolddet.trim().length()>0)
{
errCode = "VMUNCONFHD";
errList.add(errCode);
errFields.add("lot_no__from");
}
if(unconfInvReldet.trim().length()>0)
{
errCode = "VMUNCONFRL";
errList.add(errCode);
errFields.add("lot_no__from");
}
}
int errListSize = errList.size();
count = 0;
String errFldName = null;
if(errList != null && errListSize > 0)
{
for(count = 0; count < errListSize; count ++)
{
errCode = errList.get((int) count);
errFldName = errFields.get((int) count);
System.out.println("errCode .........." + errCode);
//errString = getErrorString(errFldName, errCode, userId);
System.out.println("errString-----"+errString);
errString=itmDBAccessEJB.getErrorString("",errCode,userId);
errorType = errorType(conn , errCode);
if(errString.length() > 0)
{
String bifurErrString = errString.substring(errString.indexOf("<Errors>") + 8,errString.indexOf("<trace>"));
if(errCode.equalsIgnoreCase("VMUNCONFHD"))
{
bifurErrString = bifurErrString +"<trace>Lot No: "+unconfInvHolddet.substring(0,unconfInvHolddet.length()-1)+"</trace>"+errString.substring(errString.indexOf("</trace>") + 8,errString.indexOf("</Errors>"));
}
else if(errCode.equalsIgnoreCase("VMUNCONFRL"))
{
bifurErrString = bifurErrString +"<trace>Lot No: "+unconfInvReldet.substring(0,unconfInvReldet.length()-1)+"</trace>"+errString.substring(errString.indexOf("</trace>") + 8,errString.indexOf("</Errors>"));
}
else
{
bifurErrString = bifurErrString +errString.substring(errString.indexOf("</trace>") + 8,errString.indexOf("</Errors>"));
}
errStringXml.append(bifurErrString);
errString = "";
}
if(errorType.equalsIgnoreCase("E"))
{
break;
}
}
errList.clear();
errList = null;
errFields.clear();
errFields = null;
errStringXml.append("</Errors> </Root> \r\n");
System.out.println("errStringXml-----"+errStringXml);
}
else
{
errStringXml = new StringBuffer("");
}
}catch(Exception e)
{
e.printStackTrace();
}
finally
{
try {
conn.close();
conn=null;
} catch (SQLException e) {
e.printStackTrace();
}
}
errString = errStringXml.toString();
return errString;
}
private String errorType(Connection conn , String errorCode)
{
String msgType = "";
PreparedStatement pstmt = null ;
ResultSet rs = null;
try
{
String sql = "SELECT MSG_TYPE FROM MESSAGES WHERE MSG_NO = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,errorCode);
rs = pstmt.executeQuery();
while(rs.next())
{
msgType = rs.getString("MSG_TYPE");
}
}
catch(Exception ex)
{
ex.printStackTrace();
}
finally
{
try
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
catch(Exception e)
{
e.printStackTrace();
}
}
return msgType;
}
}
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