Commit f54b2500 authored by kmandhre's avatar kmandhre

sun source merge mail by rohan


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@92848 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 1b699945
/**
* PURPOSE : EJB component CenvatCrCapitalIC for calling itm_default
* AUTHOR : Changed By sankara
*/
package ibase.webitm.ejb.dis;
import ibase.system.config.*;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import java.sql.*;
import java.text.SimpleDateFormat;
import org.w3c.dom.*;
@javax.ejb.Stateless
public class CenvatCrCapitalIC extends ValidatorEJB implements CenvatCrCapitalICLocal, CenvatCrCapitalICRemote
{
GenericUtility genericUtility = GenericUtility.getInstance();
public String itemChanged(String xmlString, String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
Document dom = null;
Document dom1 = null;
Document dom2 = null;
String valueXmlString = "";
try
{
dom = parseString(xmlString);
dom1 = parseString(xmlString1);
if (xmlString != null && xmlString.trim().length()!=0)
{
dom = genericUtility.parseString(xmlString);
}
if (xmlString1 != null && xmlString1.trim().length()!=0)
{
dom1 = genericUtility.parseString(xmlString1);
}
if (xmlString2 != null && xmlString2.trim().length()!=0)
{
dom2 = genericUtility.parseString(xmlString2);
}
valueXmlString = itemChanged( dom, dom1, dom2, objContext, currentColumn, editFlag, xtraParams );
}
catch(Exception e)
{
System.out.println("Exception : [TrainingEJB][itemChanged(String,String)] :==>\n"+e.getMessage());
throw new ITMException( e );
}
return valueXmlString;
}
public String itemChanged(Document dom, Document dom1, Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException
{
StringBuffer valueXmlString = new StringBuffer();
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null ;
int currentFormNo = 0 ;
String siteCode = "";
String chgTerm = "";
java.util.Date currDate = null;
String currDateStr = null;
ConnDriver connDriver = new ConnDriver();
GenericUtility genericUtility = GenericUtility.getInstance();
try
{
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver=null;
String applDateFormat = genericUtility.getApplDateFormat();
currDate = new java.util.Date();
SimpleDateFormat sdf = new SimpleDateFormat(applDateFormat);
currDateStr = sdf.format(currDate);
if(objContext != null && objContext.trim().length()>0)
{
currentFormNo = Integer.parseInt(objContext);
}
valueXmlString = new StringBuffer("<?xml version=\"1.0\"?><Root><header><editFlag>");
valueXmlString.append(editFlag).append("</editFlag></header>");
chgTerm = checkNull(genericUtility.getValueFromXTRA_PARAMS( xtraParams, "chgTerm" ));
System.out.println("**************ITEM DEFAULT CALLED");
switch(currentFormNo)
{
case 1 :
{
valueXmlString.append("<Detail1 domID='1' selected=\"N\">\r\n");
valueXmlString.append("<attribute selected=\"N\" updateFlag=\"A\" status=\"N\" pkNames=\"\" />\r\n");
if(currentColumn.trim().equalsIgnoreCase("itm_default"))
{
siteCode = checkNull(genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginSiteCode" ));
System.out.println("**************SITECODE="+siteCode);
valueXmlString.append("<site_code>").append("<![CDATA[" + siteCode +"]]>").append("</site_code>");
}
valueXmlString.append("</Detail1>");
}
break;
}
valueXmlString.append("</Root>");
System.out.println("=================["+valueXmlString+"]");
}
catch(Exception e)
{
e.printStackTrace();
System.out.println("Exception ::"+e.getMessage());
throw new ITMException(e);
}
finally
{
try
{
if(conn!=null)
{
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
if(conn != null)
{
conn.close();
conn = null;
}
}
}
catch(Exception d)
{
d.printStackTrace();
}
}
return valueXmlString.toString();
}
private boolean checkNumeric( String noOfLabel ) throws Exception
{
char[] cArray = noOfLabel.toCharArray();
boolean isNumber = true;
for(int i = 0; i < cArray.length;i++)
{
if( !Character.isDigit(cArray[i]) )
{
isNumber = false;
}
}
return isNumber;
}
private String checkNull(String string)
{
if(string == null)
{
string = "";
}
return string;
}
}
/**
* PURPOSE : Local Interface for CartonNoGenIC
* AUTHOR : Changed By Chaitali On 25/11/2011
*/
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.*;
@javax.ejb.Local
public interface CenvatCrCapitalICLocal extends ValidatorLocal
{
public String itemChanged() throws RemoteException,ITMException;
public String itemChanged(String xmlCurrFrmString, String xmlHdrFrmString,String xmlAllFrmString, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged(Document currDom, Document hdrDom, Document allDom, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
/**
* PURPOSE : Local Interface for CartonNoGenIC
* AUTHOR : Changed By Chaitali On 25/11/2011
*/
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
import javax.ejb.*;
@javax.ejb.Remote
public interface CenvatCrCapitalICRemote extends ValidatorRemote
{
public String itemChanged() throws RemoteException,ITMException;
public String itemChanged(String xmlCurrFrmString, String xmlHdrFrmString,String xmlAllFrmString, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged(Document currDom, Document hdrDom, Document allDom, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.dis;
import ibase.system.config.ConnDriver;
import ibase.utility.CommonConstants;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.TransIDGenerator;
import ibase.webitm.ejb.*;
import java.rmi.RemoteException;
import java.sql.*;
import java.sql.Date;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.*;
//import java.util.Date;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
@javax.ejb.Stateless
public class CenvatCrCapitalPrc extends ProcessEJB implements CenvatCrCapitalPrcLocal,CenvatCrCapitalPrcRemote //SessionBean
{
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
DistCommon discommon = new DistCommon();
int noRows = 0;
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
{
String rtrStr = "";
Document headerDom = null;
Document detailDom = null;
System.out.println("getData(xmlString,xmlString2,windowName,xtraParams CALLEDRohan..."+ xmlString);
try
{
if(xmlString != null && xmlString.trim().length()!=0)
{
System.out.println("XML String :"+xmlString);
headerDom = genericUtility.parseString(xmlString);
}
if(xmlString2 != null && xmlString2.trim().length()!=0)
{
System.out.println("XML String :"+xmlString2);
detailDom = genericUtility.parseString(xmlString2);
}
rtrStr = getData(headerDom, detailDom, windowName, xtraParams);
}
catch (Exception e)
{
System.out.println("Exception :CenVatCrCapitalPrc :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
rtrStr = e.getMessage();
}
return rtrStr;
}
public String getData(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException
{
String siteCode = "";
String acctPrd = "";
String prcDate = "";
String errCode = "";
String errString = "";
String getDataSql= "" ;
String resultString = "";
StringBuffer retTabSepStrBuff = new StringBuffer();
String dataCntSql = "";
String acctPrdSql = "";
java.util.Date processDate = null;
java.util.Date dateCheck = null;
int count = 0;
noRows = 0;
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
siteCode = genericUtility.getColumnValue("site_code",headerDom);
if ( siteCode == null || siteCode.trim().length() == 0 )
{
siteCode = "";
System.out.println("Site Code From is Null...");
errString = itmDBAccessEJB.getErrorString("","VTNULSITE","","",conn);
return errString;
}
System.out.println(" SITE CODE ::"+ siteCode);
acctPrd = genericUtility.getColumnValue("acct_period",headerDom);
if ( acctPrd == null || acctPrd.trim().length() == 0 )
{
acctPrd = "";
System.out.println(" Period is Null...");
errString = itmDBAccessEJB.getErrorString("","VTNULLPRD","","",conn);
return errString;
}
System.out.println(" PERIOD ::"+ acctPrd);
prcDate = genericUtility.getColumnValue("process_date",headerDom);
if ( prcDate == null || prcDate.trim().length() == 0 )
{
prcDate = "";
System.out.println(" Proecss Date is Null...");
errString = itmDBAccessEJB.getErrorString("","VTNULLPRC","","",conn);
return errString;
}
acctPrdSql = "SELECT COUNT(*) AS COUNT FROM PERIOD WHERE ACCT_PRD = ? ";
pstmt = conn.prepareStatement(acctPrdSql);
pstmt.setString(1,acctPrd);
rs = pstmt.executeQuery();
if(rs.next())
{
count = rs.getInt("COUNT");
}
if(count == 0)
{
errString = itmDBAccessEJB.getErrorString("","VTINVLDPRD","","",conn);
return errString;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
String applDateFmt = genericUtility.getApplDateFormat();
DateFormat dtFormat = new SimpleDateFormat(applDateFmt);
processDate = dtFormat.parse(prcDate);
java.sql.Date processSqlDate = new java.sql.Date(processDate.getTime());
String year = acctPrd.substring(2, 4);
String chkDate = "01/04/"+year;
dateCheck = dtFormat.parse(chkDate);
if (dateCheck.after(processDate))
{
resultString = itmDBAccessEJB.getErrorString("","VTNTVALDAT","","",conn);
return resultString;
}
//to check all row select.start
dataCntSql = "SELECT COUNT(*) AS COUNT FROM CENVAT_CR_CAPITAL WHERE CONFIRMED = ? "
+" AND SITE_CODE = ? AND PROCESS_YEAR = ? AND CASE WHEN PROCESS IS NULL THEN 'N' ELSE PROCESS end <> 'Y' ORDER BY BAL_GROUP ";
pstmt = conn.prepareStatement(dataCntSql);
pstmt.setString(1,"Y");
pstmt.setString(2,siteCode);
pstmt.setString(3,acctPrd);
rs = pstmt.executeQuery();
if(rs.next())
{
noRows = rs.getInt("COUNT");
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
//to check all row select.end
getDataSql = "SELECT TRAN_ID,TRAN_DATE,BAL_GROUP,REF_SER,REF_ID,REF_DATE,CONFIRMED,"
+" DRCR_FLAG,PARTY_REF,NET_AMT,TAX_AMT,SITE_CODE,SUPP_CODE,TAX_CODE,"
+" REF_DOC_NO,REF_DOC_DATE,SR_NO,BAL_GROUP__ADJ,ADJ_AMT,CR_AMT,CHG_DATE,CHG_USER,CHG_TERM"
+" FROM CENVAT_CR_CAPITAL WHERE CONFIRMED = ? "
+" AND SITE_CODE = ? AND PROCESS_YEAR = ? AND CASE WHEN PROCESS IS NULL THEN 'N' ELSE PROCESS end <> 'Y' ORDER BY BAL_GROUP ";
pstmt = conn.prepareStatement(getDataSql);
pstmt.setString(1,"Y");
pstmt.setString(2,siteCode);
pstmt.setString(3,acctPrd);
rs = pstmt.executeQuery();
if(rs.next())
{
do
{
retTabSepStrBuff.append(checkNull(rs.getString("TRAN_ID"))).append("\t");
retTabSepStrBuff.append(rs.getDate("TRAN_DATE")).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("BAL_GROUP"))).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("REF_SER"))).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("REF_ID"))).append("\t");
retTabSepStrBuff.append(rs.getDate("REF_DATE")).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("CONFIRMED"))).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("DRCR_FLAG"))).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("PARTY_REF"))).append("\t");
retTabSepStrBuff.append(rs.getDouble("NET_AMT")).append("\t");
retTabSepStrBuff.append(rs.getDouble("TAX_AMT")).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("SITE_CODE"))).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("SUPP_CODE"))).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("TAX_CODE"))).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("REF_DOC_NO"))).append("\t");
retTabSepStrBuff.append(rs.getDate("REF_DOC_DATE")).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("SR_NO"))).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("BAL_GROUP__ADJ"))).append("\t");
retTabSepStrBuff.append(rs.getDouble("ADJ_AMT")).append("\t");
retTabSepStrBuff.append(rs.getDouble("CR_AMT")).append("\t");
retTabSepStrBuff.append(rs.getDate("CHG_DATE")).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("CHG_USER"))).append("\t");
retTabSepStrBuff.append(checkNull(rs.getString("CHG_TERM"))).append("\t");
retTabSepStrBuff.append("\n");
}while(rs.next());
resultString = retTabSepStrBuff.toString();
System.out.println("ResultString....." + resultString);
pstmt.clearParameters();
}
else
{
errCode ="VTNOTREC";
}
if (!errCode.equals(""))
{
resultString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn);
System.out.println("resultString: "+resultString);
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(rs != null)
{
rs.close();
rs = null;
}
}
catch (SQLException e)
{
System.out.println("SQLException :CenVatCrCapitalPrc :getData(Document headerDom, Document detailDom, String windowName, String xtraParams):" + e.getMessage() + ":");
throw new ITMException(e);
}
catch (Exception e)
{
System.out.println("Exception :CenVatCrCapitalPrc :getData(Document headerDom, Document detailDom, String windowName, String xtraParams):" + e.getMessage() + ":");
throw new ITMException(e);
}
finally
{
try
{
if(conn != null)
{
conn.close();
conn = null;
}
}
catch(Exception e)
{
errString = e.getMessage();
e.printStackTrace();
throw new ITMException(e);
}
}
return resultString;
}
//Process method
public String process() throws RemoteException,ITMException
{
return "";
}
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
{
String retStr = "";
Document detailDom = null;
Document headerDom = null;
GenericUtility genericUtility = GenericUtility.getInstance();
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 :CenVatCrCapitalPrc :process(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
e.printStackTrace();
retStr = e.getMessage();
throw new ITMException(e);
}
return retStr;
}
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException
{
String errString = "";
String balPrd = "";
String balGrp = "";
String siteCode = "";
String finEntity = "";
String childNodeName = "";
String prcDate = "";
String adjAmount = "";
String netAmount = "";
String crAmount = "";
String taxAmount = "";
String insetSql ="";
String chgUser = "";
String chgTerm = "";
String currBalprd = "";
String prd = "";
String dateStr = "";
String tranIdProc = "";
String tranIdCr = "";
String docType = "";
String balType = "";
String refSer = "";
String drCr = "";
String taxChap = "";
String itemCode = "";
String suppCode = "";
String exeRef = "";
String suppSiteCode = "";
String tranSiteCode = "";
String transtranType = "";
String chapHead = "";
String lotNo = "";
String invoiceNo = "";
String taxCode = "";
String lotSl = "";
String matCate = "";
String refId = "";
String refLine = "";
String tranType = "";
String balGrpAdj = "";
String sqlCp = "";
String srNo = "";
String delimiter = ":";
String chktax = "";
String chkbalPrd = "";
String updateTaxBal = "";
String processYear = "";
String sqlFinEntity = "";
String insertTaxPrc = "";
String updateSql = "";
PreparedStatement pstmtUpdate = null;
PreparedStatement pstmttax = null;
PreparedStatement pstmtCapital = null;
PreparedStatement pstmtbalPrd = null;
PreparedStatement pstmtFinEntity = null;
PreparedStatement pstmt = null;
PreparedStatement pstmtTaxPrc = null;
PreparedStatement pstmtUpdateCr = null;
ResultSet rsTax = null;
ResultSet rsCapital = null;
ResultSet rsFin = null;
Double addlExcise = 0.0;
Double qtyReq = 0.0;
Double closeStk = 0.0;
java.util.Date processDate = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
int parentNodeListLength = 0;
int childNodeListLength = 0;
int date = 0;
int month=0;
int year=0;
int recordcnt = 0;
int balcnt = 0;
double adjAmt = 0.0;
double netAmt = 0.0;
double crAmt = 0.0;
double taxAmt = 0.0;
Calendar cal = Calendar.getInstance();
HashMap<String,String> balGroupMap = new HashMap<String,String>();
ResultSet rs = null;
NodeList parentNodeList = null;
Connection conn = null;
try
{
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
prcDate = genericUtility.getColumnValue("process_date",headerDom);
chgUser = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" );
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "termId");
siteCode = checkNull(genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginSiteCode" ));
String applDateFmt = genericUtility.getApplDateFormat();
DateFormat dtFormat = new SimpleDateFormat(applDateFmt);
processDate = dtFormat.parse(prcDate);
java.util.Date utilDate = new java.util.Date();
java.sql.Date chgDate = new java.sql.Date(utilDate.getTime());
java.sql.Date processSqlDate = new java.sql.Date(processDate.getTime());
//calculating balance period.start
java.sql.Date tranDate = processSqlDate;
cal.setTime(tranDate);
date=cal.get(Calendar.DATE);
month=cal.get(Calendar.MONTH);
year=cal.get(Calendar.YEAR);
dateStr= new Integer(year).toString()+"-"+(new java.text.DecimalFormat( "00" )).format( month + 1)+"-"+(new java.text.DecimalFormat( "00" )).format( date );
System.out.println("dateStr:::["+dateStr+"]");
System.out.println("timestamp dateStr :::["+dateStr+" 00:00:00.0]");
Timestamp currTranDate = java.sql.Timestamp.valueOf(dateStr+" 00:00:00.0");
prd = (currTranDate.toString()).substring(0,currTranDate.toString().indexOf(" "));
String FltStr[] = prd.split("-");
currBalprd = FltStr[0]+FltStr[1]+FltStr[2];
System.out.println("currBalPeriod::::::::::::["+currBalprd+"]");
//calculating balance period.end
parentNodeList = detailDom.getElementsByTagName("Detail2");
parentNodeListLength = parentNodeList.getLength();
System.out.println("noRows***"+noRows+"parentNodeListLength***"+parentNodeListLength);
if(noRows != parentNodeListLength )
{
errString = itmDBAccessEJB.getErrorString("","VTNTSELECT","","",conn);
return errString;
}
else
{
refId = getTranId("t_transfer_refId",siteCode,conn);
}
for (int selectedRow = 0; selectedRow < parentNodeListLength; selectedRow++)
{
parentNode = parentNodeList.item(selectedRow);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for (int childRow = 0; childRow < childNodeListLength; childRow++)
{
childNode = childNodeList.item(childRow);
childNodeName = childNode.getNodeName();
if (childNodeName.equals("tran_id"))
{
tranIdCr = childNode.getFirstChild().getNodeValue();
}
if (childNodeName.equals("bal_group"))
{
balGrp = childNode.getFirstChild().getNodeValue();
}
if (childNodeName.equals("adj_amt"))
{
adjAmount = childNode.getFirstChild().getNodeValue();
}
if (childNodeName.equals("net_amt"))
{
netAmount = childNode.getFirstChild().getNodeValue();
}
if (childNodeName.equals("cr_amt"))
{
crAmount = childNode.getFirstChild().getNodeValue();
}
if (childNodeName.equals("tax_amt"))
{
taxAmount = childNode.getFirstChild().getNodeValue();
}
}
//Adding to hashmap.start
if(!balGroupMap.containsKey(balGrp))
{
balGroupMap.put(balGrp, adjAmount+":"+netAmount+":"+crAmount+":"+taxAmount+":"+tranIdCr);
}
else
{
String amtStr = balGroupMap.get(balGrp);
String[] amtArray;
amtArray = amtStr.split(delimiter);
adjAmt = Double.parseDouble(amtArray[0]) + Double.parseDouble(adjAmount);
netAmt = Double.parseDouble(amtArray[1]) + Double.parseDouble(netAmount);
crAmt = Double.parseDouble(amtArray[2]) + Double.parseDouble(crAmount);
taxAmt = Double.parseDouble(amtArray[3]) + Double.parseDouble(taxAmount);
balGroupMap.put(balGrp,String.valueOf(adjAmt)+":"+String.valueOf(netAmt)+":"+String.valueOf(crAmt)+":"+String.valueOf(taxAmt)+":"+amtArray[4]);
}
}//
//to get fin entity.start
sqlFinEntity = "SELECT FIN_ENTITY FROM SITE WHERE SITE_CODE = ?";
pstmtFinEntity = conn.prepareStatement(sqlFinEntity);
pstmtFinEntity.setString(1,siteCode);
rsFin = pstmtFinEntity.executeQuery();
if(rsFin.next())
{
finEntity = checkNull(rsFin.getString("FIN_ENTITY"));
}
if(rsFin != null)
{
rsFin.close();
rsFin = null;
}
if(pstmtFinEntity != null)
{
pstmtFinEntity.close();
pstmtFinEntity = null;
}
//to get fin entity.end
sqlCp = "SELECT DOC_TYPE, BAL_TYPE,BAL_PRD, REF_SER, DRCR_FLAG,TAX_CHAP, ITEM_CODE, SITE_CODE, QTY_RECD, SUPP_CODE, EXC_REF,"
+" CLOSING_STOCK, SITE_CODE__SUPP, SITE_CODE__TRAN, TRAN_TYPE_TRANSACTION,CHAP_HEADING, LOT_NO, INVOICE_NO,"
+" TAX_CODE,REF_DOC_NO, REF_DOC_DATE, LOT_SL, MATERIAL_CATEGORY, REF_ID,REF_DATE,REF_LINE,TRAN_TYPE,"
+" BAL_GROUP__ADJ, ADDL_EXCISE,PROCESS_YEAR FROM CENVAT_CR_CAPITAL WHERE TRAN_ID = ? ";
pstmtCapital = conn.prepareStatement(sqlCp);
insetSql = "INSERT INTO TAX_PROCESS_BAL (BAL_GROUP, BAL_PRD, DR_AMT, CR_AMT, CHG_DATE, CHG_USER, CHG_TERM, "
+" ACCT_PRD, FIN_ENTITY, SITE_CODE) VALUES (?,?,?,?,?,?,?,?,?,?)";
pstmt = conn.prepareStatement(insetSql);
chkbalPrd = "SELECT COUNT(*) AS CNT FROM TAX_PROCESS_BAL WHERE BAL_GROUP = ? AND BAL_PRD = ? AND ACCT_PRD = ?"
+" AND FIN_ENTITY = ? AND SITE_CODE = ?";
pstmtbalPrd = conn.prepareStatement(chkbalPrd);
chktax = "SELECT COUNT(*) AS COUNT FROM TAX_PROCESS_BAL WHERE BAL_GROUP = ? AND ACCT_PRD = ?"
+" AND FIN_ENTITY = ? AND SITE_CODE = ?";
pstmttax = conn.prepareStatement(chktax);
insertTaxPrc = "INSERT INTO TAX_PROCESSED (TRAN_ID, TRAN_DATE, BAL_GROUP, DOC_TYPE, BAL_TYPE, BAL_PRD, REF_SER, DRCR_FLAG, " +
" NET_AMT, DR_AMT, CR_AMT, TAX_CHAP, ITEM_CODE, SITE_CODE, QTY_RECD, SUPP_CODE, EXC_REF, CLOSING_STOCK, " +
" SITE_CODE__SUPP, SITE_CODE__TRAN, TRAN_TYPE_TRANSACTION, PROCESS_YN, CHAP_HEADING, LOT_NO, TAX_AMT, " +
" INVOICE_NO, TAX_CODE, CHG_DATE, CHG_USER, CHG_TERM,LOT_SL, MATERIAL_CATEGORY, " +
" REF_ID,REF_LINE,REF_DATE,TRAN_TYPE, SR_NO,BAL_GROUP__ADJ, ADJ_AMT, ADDL_EXCISE ) " +
" VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
pstmtTaxPrc = conn.prepareStatement(insertTaxPrc);
updateTaxBal = "UPDATE TAX_PROCESS_BAL SET CR_AMT = CR_AMT + ? WHERE BAL_GROUP = ? AND BAL_PRD = ? AND ACCT_PRD = ? "
+" AND FIN_ENTITY = ? AND SITE_CODE = ? ";
pstmtUpdate = conn.prepareStatement(updateTaxBal);
//srNo = getUniqueKey(conn, "t_tax_process_sr_no", prcDate,siteCode,"",balType,balPrd,refSer,drCr,docType,refId,itemCode,taxCode,suppCode,taxChap,matCate);
//System.out.println("Only one serial no is generate***"+srNo);
//Changed by Rohan on 12-1-13 To genrate unique serial no irrespective of group
boolean isSerialGen = false;
for (String keyBalGrp : balGroupMap.keySet())
{
String str = balGroupMap.get(keyBalGrp);
String[] amtArrayIns;
amtArrayIns = str.split(delimiter);
adjAmt = Double.parseDouble(amtArrayIns[0]);
netAmt = Double.parseDouble(amtArrayIns[1]);
crAmt = Double.parseDouble(amtArrayIns[2]);
taxAmt = Double.parseDouble(amtArrayIns[3]);
tranIdCr = amtArrayIns[4];
/*
sqlCp = "SELECT DOC_TYPE, BAL_TYPE, REF_SER, DRCR_FLAG,TAX_CHAP, ITEM_CODE, SITE_CODE, QTY_RECD, SUPP_CODE, EXC_REF,"
+" CLOSING_STOCK, SITE_CODE__SUPP, SITE_CODE__TRAN, TRAN_TYPE_TRANSACTION,CHAP_HEADING, LOT_NO, INVOICE_NO,"
+" TAX_CODE,REF_DOC_NO, REF_DOC_DATE, LOT_SL, MATERIAL_CATEGORY, REF_ID,REF_DATE,REF_LINE,TRAN_TYPE,"
+" BAL_GROUP__ADJ, ADDL_EXCISE FROM CENVAT_CR_CAPITAL WHERE TRAN_ID = ? ";
pstmtCapital = conn.prepareStatement(sqlCp);
*/
pstmtCapital.setString(1, tranIdCr);
rsCapital = pstmtCapital.executeQuery();
if(rsCapital.next())
{
docType = checkNull(rsCapital.getString("DOC_TYPE"));
balType = checkNull(rsCapital.getString("BAL_TYPE"));
balPrd = checkNull(rsCapital.getString("BAL_PRD"));
refSer = checkNull(rsCapital.getString("REF_SER"));
drCr = checkNull(rsCapital.getString("DRCR_FLAG"));
taxChap = checkNull(rsCapital.getString("TAX_CHAP"));
itemCode = checkNull(rsCapital.getString("ITEM_CODE"));
qtyReq = rsCapital.getDouble("QTY_RECD");
suppCode = checkNull(rsCapital.getString("SUPP_CODE"));
exeRef = checkNull(rsCapital.getString("EXC_REF"));
closeStk = rsCapital.getDouble("CLOSING_STOCK");
suppSiteCode = checkNull(rsCapital.getString("SITE_CODE__SUPP"));
tranSiteCode = checkNull(rsCapital.getString("SITE_CODE__TRAN"));
transtranType = checkNull(rsCapital.getString("TRAN_TYPE_TRANSACTION"));
chapHead = checkNull(rsCapital.getString("CHAP_HEADING"));
lotNo = checkNull(rsCapital.getString("LOT_NO"));
invoiceNo = checkNull(rsCapital.getString("INVOICE_NO"));
taxCode = checkNull(rsCapital.getString("TAX_CODE"));
//refDocNo = checkNull(rsCapital.getString("REF_DOC_NO"));
//refDocDate = rsCapital.getDate("REF_DOC_DATE");
lotSl = checkNull(rsCapital.getString("LOT_SL"));
matCate = checkNull(rsCapital.getString("MATERIAL_CATEGORY"));
//refDate = rsCapital.getDate("REF_DATE");
//refId = checkNull(rsCapital.getString("REF_ID"));
refLine = checkNull(rsCapital.getString("REF_LINE"));
tranType = checkNull(rsCapital.getString("TRAN_TYPE"));
balGrpAdj = checkNull(rsCapital.getString("BAL_GROUP__ADJ"));
addlExcise = rsCapital.getDouble("ADDL_EXCISE");
processYear = checkNull(rsCapital.getString("PROCESS_YEAR"));
}
pstmtCapital.clearParameters();
if(rsCapital != null)
{
rsCapital.close();
rsCapital = null;
}
//inserting data into tax process bal.start
//opening balance insert.start
/*
insetSql = "INSERT INTO TAX_PROCESS_BAL (BAL_GROUP, BAL_PRD, DR_AMT, CR_AMT, CHG_DATE, CHG_USER, CHG_TERM, "
+" ACCT_PRD, FIN_ENTITY, SITE_CODE) VALUES (?,?,?,?,?,?,?,?,?,?)";
pstmt = conn.prepareStatement(insetSql);
*/
/*
chktax = "SELECT COUNT(*) AS COUNT FROM TAX_PROCESS_BAL WHERE BAL_GROUP = ? AND ACCT_PRD = ?"
+" AND FIN_ENTITY = ? AND SITE_CODE = ?";
pstmttax = conn.prepareStatement(chktax);
*/
pstmttax.setString(1, keyBalGrp);
pstmttax.setString(2,processYear);//balance group
pstmttax.setString(3, finEntity); //balance period
pstmttax.setString(4,siteCode); //debit amount
rsTax = pstmttax.executeQuery();
if(rsTax.next())
{
recordcnt = rsTax.getInt("COUNT");
}
pstmttax.clearParameters();
if(rsTax != null)
{
rsTax.close();
rsTax = null;
}
if(recordcnt > 0)
{
//only update SQL
/*
updateTaxBal = "UPDATE TAX_PROCESS_BAL SET CR_AMT = CR_AMT + ? WHERE BAL_GROUP = ? AND BAL_PRD = ? AND ACCT_PRD = ? "
+" AND FIN_ENTITY = ? AND SITE_CODE = ? ";
pstmtUpdate = conn.prepareStatement(updateTaxBal);
*/
pstmtUpdate.setDouble(1,adjAmt);
pstmtUpdate.setString(2,keyBalGrp);
pstmtUpdate.setString(3, "ZZZZZZ ");
pstmtUpdate.setString(4,processYear);
pstmtUpdate.setString(5,finEntity);
pstmtUpdate.setString(6,siteCode);
pstmtUpdate.executeUpdate();
}
else
{
pstmt.setString(1, keyBalGrp); //balance group
pstmt.setString(2, "000000 "); //balance period
pstmt.setDouble(3, 0.0); //debit amount
pstmt.setDouble(4, 0.0);
pstmt.setDate(5, chgDate); //change date
pstmt.setString(6, chgUser);
pstmt.setString(7, chgTerm); //change terminal number
pstmt.setString(8,processYear); //accounting year
pstmt.setString(9,finEntity); //fin entity
pstmt.setString(10,siteCode); //site code
pstmt.executeUpdate();
pstmt.clearParameters();
//opening balance insert.end
//closing balance insert.start
pstmt.setString(1, keyBalGrp);
pstmt.setString(2, "ZZZZZZ ");
pstmt.setDouble(3, 0.0);
pstmt.setDouble(4, adjAmt);
pstmt.setDate(5, chgDate);
pstmt.setString(6, chgUser);
pstmt.setString(7, chgTerm);
pstmt.setString(8,processYear);
pstmt.setString(9,finEntity);
pstmt.setString(10,siteCode);
pstmt.executeUpdate();
pstmt.clearParameters();
//closing balance insert.start
}
/*
chkbalPrd = "SELECT COUNT(*) AS CNT FROM TAX_PROCESS_BAL WHERE BAL_GROUP = ? AND BAL_PRD = ? AND ACCT_PRD = ?"
+" AND FIN_ENTITY = ? AND SITE_CODE = ?";
pstmtbalPrd = conn.prepareStatement(chkbalPrd);
*/
pstmtbalPrd.setString(1, keyBalGrp);
pstmtbalPrd.setString(2,currBalprd);//balance group
pstmtbalPrd.setString(3,processYear);
pstmtbalPrd.setString(4, finEntity); //balance period
pstmtbalPrd.setString(5,siteCode); //debit amount
rsTax = pstmtbalPrd.executeQuery();
if(rsTax.next())
{
balcnt = rsTax.getInt("CNT");
}
if(rsTax != null)
{
rsTax.close();
rsTax = null;
}
if(balcnt > 0)
{
//update only
pstmtUpdate.setDouble(1,adjAmt);
pstmtUpdate.setString(2,keyBalGrp);
pstmtUpdate.setString(3, currBalprd);
pstmtUpdate.setString(4,processYear);
pstmtUpdate.setString(5,finEntity);
pstmtUpdate.setString(6,siteCode);
pstmtUpdate.executeUpdate();
}
else
{
pstmt.setString(1, keyBalGrp);
pstmt.setString(2,currBalprd);
pstmt.setDouble(3, 0.0);
pstmt.setDouble(4, adjAmt);
pstmt.setDate(5, chgDate);
pstmt.setString(6, chgUser);
pstmt.setString(7, chgTerm);
pstmt.setString(8,processYear);
pstmt.setString(9,finEntity);
pstmt.setString(10,siteCode);
pstmt.executeUpdate();
pstmt.clearParameters();
}
if(rs != null)
{
rs.close();
rs = null;
}
//inserting data into tax process bal.end
//tax.start
/*
insertTaxPrc = "INSERT INTO TAX_PROCESSED (TRAN_ID, TRAN_DATE, BAL_GROUP, DOC_TYPE, BAL_TYPE, BAL_PRD, REF_SER, DRCR_FLAG, " +
" NET_AMT, DR_AMT, CR_AMT, TAX_CHAP, ITEM_CODE, SITE_CODE, QTY_RECD, SUPP_CODE, EXC_REF, CLOSING_STOCK, " +
" SITE_CODE__SUPP, SITE_CODE__TRAN, TRAN_TYPE_TRANSACTION, PROCESS_YN, CHAP_HEADING, LOT_NO, TAX_AMT, " +
" INVOICE_NO, TAX_CODE, CHG_DATE, CHG_USER, CHG_TERM, REF_DOC_NO, REF_DOC_DATE, LOT_SL, MATERIAL_CATEGORY, " +
" REF_ID,REF_DATE,REF_LINE,TRAN_TYPE, SR_NO,BAL_GROUP__ADJ, ADJ_AMT, ADDL_EXCISE ) " +
" VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
pstmtTaxPrc = conn.prepareStatement(insertTaxPrc);
*/
//getTranId
//Changed by Rohan on 12/06/12 for bug fixing
/*
srNo = getTranId("t_tax_process_sr_no",siteCode,conn);
*/
tranIdProc = getUniqueKey(conn, "T_tax_processed", prcDate,siteCode,keyBalGrp,balType,balPrd,refSer,drCr,docType,refId,itemCode,taxCode,suppCode,taxChap,matCate);
//Changed by Rohan on 12-1-12 To genrate unique serial no irrespective of group
//srNo = getUniqueKey(conn, "t_tax_process_sr_no", prcDate,siteCode,keyBalGrp,balType,balPrd,refSer,drCr,docType,refId,itemCode,taxCode,suppCode,taxChap,matCate);
if(!isSerialGen)
{
srNo = getUniqueKey(conn, "t_tax_process_sr_no", prcDate,siteCode,keyBalGrp,balType,balPrd,refSer,drCr,docType,refId,itemCode,taxCode,suppCode,taxChap,matCate);
isSerialGen = true;
}
pstmtTaxPrc.setString(1, tranIdProc);//transaction id
pstmtTaxPrc.setDate(2,processSqlDate);
pstmtTaxPrc.setString(3,keyBalGrp); //balance group
pstmtTaxPrc.setString(4, docType); //document type
pstmtTaxPrc.setString(5, balType); //balance type
pstmtTaxPrc.setString(6, balPrd); //balance period
pstmtTaxPrc.setString(7, refSer); //referance series
pstmtTaxPrc.setString(8, drCr); //dr / cr flag
pstmtTaxPrc.setDouble(9, netAmt); //net amount
pstmtTaxPrc.setDouble(10, 0.0); //debit amount
pstmtTaxPrc.setDouble(11, crAmt); //credit amount
pstmtTaxPrc.setString(12, taxChap); //tax chapter
pstmtTaxPrc.setString(13, itemCode); //item code
pstmtTaxPrc.setString(14, siteCode); //site code
pstmtTaxPrc.setDouble(15, qtyReq); //quantity received
pstmtTaxPrc.setString(16, suppCode); //supplier code
pstmtTaxPrc.setString(17, exeRef); //exc referance
pstmtTaxPrc.setDouble(18, closeStk); //closing stock
pstmtTaxPrc.setString(19, suppSiteCode); //site code supplier
pstmtTaxPrc.setString(20, tranSiteCode); //site code transaction
pstmtTaxPrc.setString(21, transtranType); //tran type transaction
pstmtTaxPrc.setString(22, "Y"); //confirmation flag
pstmtTaxPrc.setString(23, chapHead); //chapter heading
pstmtTaxPrc.setString(24, lotNo); //lot number
pstmtTaxPrc.setDouble(25, taxAmt); //tax amount
pstmtTaxPrc.setString(26, invoiceNo); //invoice number
pstmtTaxPrc.setString(27, taxCode); //tax code
pstmtTaxPrc.setDate(28, chgDate); //change date
pstmtTaxPrc.setString(29, chgUser); //change user
pstmtTaxPrc.setString(30, chgTerm); //change terminal number
//pstmtTaxPrc.setString(31, refId); //referance document number
//pstmtTaxPrc.setDate(32, processSqlDate); //referance document date
pstmtTaxPrc.setString(31, lotSl); //lot sl
pstmtTaxPrc.setString(32, matCate); //material category
pstmtTaxPrc.setString(33, refId); //Ref Id
pstmtTaxPrc.setString(34, refLine); //referance line number
pstmtTaxPrc.setDate(35, processSqlDate); //Ref Date
pstmtTaxPrc.setString(36, tranType); //Tran Type
pstmtTaxPrc.setString(37, srNo);
pstmtTaxPrc.setString(38, balGrpAdj); //bal group adj
pstmtTaxPrc.setDouble(39, adjAmt); //adj amt
pstmtTaxPrc.setDouble(40, addlExcise); // 06-01-2006 manoharan new column
pstmtTaxPrc.executeUpdate();
pstmtTaxPrc.clearParameters();
//tax.end
//UPDATING FLAG OF CENVAT.start
updateSql = "UPDATE CENVAT_CR_CAPITAL SET PROCESS = ? WHERE BAL_GROUP = ? AND PROCESS_YEAR = ? AND CONFIRMED = ?";
pstmtUpdateCr = conn.prepareStatement(updateSql);
pstmtUpdateCr.setString(1,"Y");
pstmtUpdateCr.setString(2,keyBalGrp);
pstmtUpdateCr.setString(3,processYear);
pstmtUpdateCr.setString(4,"Y");
pstmtUpdateCr.executeUpdate();
pstmtUpdateCr.clearParameters();
}
}
catch(Exception e)
{
if ( conn != null && ! conn.isClosed() )
{
conn.rollback();
}
e.printStackTrace();
System.out.println("Exception :CenVatCrCapitalPrc :process(String xmlString2, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
errString = e.getMessage();
//return errString ;
throw e;
}
finally
{
System.out.println("Closing Connection....");
try
{
if(pstmtUpdateCr != null)
{
pstmtUpdateCr.close();
pstmtUpdateCr = null;
}
if(pstmtTaxPrc != null)
{
pstmtTaxPrc.close();
pstmtTaxPrc = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(pstmtUpdate != null)
{
pstmtUpdate.close();
pstmtUpdate = null;
}
if(pstmtbalPrd != null)
{
pstmtbalPrd.close();
pstmtbalPrd = null;
}
if(pstmttax != null)
{
pstmttax.close();
pstmttax = null;
}
if(pstmtCapital != null)
{
pstmtCapital.close();
pstmtCapital = null;
}
if (errString == null || errString.trim().length() == 0)
{
conn.commit();
errString="VTCOMPLETE";
errString = itmDBAccessEJB.getErrorString("",errString,"","",conn);
return errString;
}
else
{
System.out.println("errString.indexOf(<Errors>)---------------"+errString.indexOf("<Errors>"));
if(errString.indexOf("<Errors>") == -1 )
{
if( errString.trim().length() > 0)
{
System.out.println("Inside Block for ErrOr Not Found---------------");
errString="VTPRCESERR";
errString = itmDBAccessEJB.getErrorString("",errString,"","",conn);
}
}
return errString;
}
}
catch(Exception e)
{
errString = e.getMessage();
e.printStackTrace();
return errString ;
}
}
}
private String checkNull( String input )
{
if( input == null )
{
input = "";
}
return input;
}
private String getTranId(String windowName,String siteCode,Connection conn) throws ITMException
{
String keyStringQuery = "";
String xmlValues = "";
String tranId = "";
ResultSet rSet = null ;
PreparedStatement pstmt = null;
//CommonConstants commonConstants = new CommonConstants();
java.sql.Timestamp currDate = null;
try
{
keyStringQuery = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE TRAN_WINDOW = ?";
pstmt = conn.prepareStatement(keyStringQuery);
pstmt.setString(1,windowName);
rSet = pstmt.executeQuery();
String tranSer1 = "";
String keyString = "";
String keyCol = "";
if (rSet.next())
{
keyString = rSet.getString("KEY_STRING");
keyCol = rSet.getString("TRAN_ID_COL");
tranSer1 = rSet.getString("REF_SER");
}
SimpleDateFormat sdfAppl = new SimpleDateFormat(genericUtility.getApplDateFormat());
currDate = new java.sql.Timestamp(System.currentTimeMillis());
String currDateStr = sdfAppl.format(currDate);
System.out.println("keyString :"+keyString);
System.out.println("keyCol :"+keyCol);
System.out.println("tranSer1 :"+tranSer1);
xmlValues ="<?xml version=\"1.0\" encoding=\"utf-8\"?><Root>";
xmlValues = xmlValues + "<Header></Header>";
xmlValues = xmlValues + "<Detail1>";
xmlValues = xmlValues + "<tran_id></tran_id>";
xmlValues = xmlValues + "<site_code>" + siteCode + "</site_code>";
xmlValues = xmlValues + "<desp_date>" + currDateStr + "</desp_date>";
xmlValues = xmlValues + "<tran_date>" + currDateStr + "</tran_date>";
xmlValues = xmlValues + "</Detail1></Root>";
System.out.println("xmlValues :["+xmlValues+"]");
TransIDGenerator tg = new TransIDGenerator(xmlValues, "BASE", CommonConstants.DB_NAME);
//crating new ID
tranId = tg.generateTranSeqID(tranSer1, keyCol, keyString, conn);
if(rSet != null)
{
rSet.close();
rSet=null;
}
if(pstmt != null)
{
pstmt.close();
pstmt=null;
}
}
catch(Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if(rSet != null)
{
rSet.close();
rSet=null;
}
if(pstmt != null)
{
pstmt.close();
pstmt=null;
}
}
catch(Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
}
return checkNull( tranId);
}
private String getUniqueKey(Connection con, String winName, String tranDate,String siteCode,String balGrp,String balType,String balPrd,String refSer,String drCr,
String docType,String refId,String itemCode,String taxCode,String suppCode,String taxChap,String matCate )throws ITMException
{
String uniqueKey = null;
String xmlValues = "";
try
{
System.out.println("Generating Primary Key ..........."+tranDate);
xmlValues ="<?xml version=\"1.0\" encoding=\"utf-8\"?><Root>";
xmlValues = xmlValues + "<Header></Header>";
xmlValues = xmlValues + "<Detail1>";
xmlValues = xmlValues + "<sr_no><![CDATA[]]></sr_no>";
xmlValues = xmlValues +"<site_code><![CDATA[" + siteCode + "]]></site_code>";
xmlValues = xmlValues +"<tran_date><![CDATA[" + tranDate + "]]></tran_date>";
// to generate sr_no based on any of the value.start
xmlValues = xmlValues +"<bal_group><![CDATA[" + balGrp + "]]></bal_group>";
xmlValues = xmlValues +"<bal_type><![CDATA[" + balType + "]]></bal_type>";
xmlValues = xmlValues +"<bal_prd><![CDATA[" + balPrd + "]]></bal_prd>";
xmlValues = xmlValues +"<ref_ser><![CDATA[" + refSer + "]]></ref_ser>";
xmlValues = xmlValues +"<drcr_flag><![CDATA[" + drCr + "]]></drcr_flag>";
xmlValues = xmlValues +"<bal_group__adj><![CDATA[" + balGrp + "]]></bal_group__adj>";
xmlValues = xmlValues +"<doc_type><![CDATA[" + docType + "]]></doc_type>";
xmlValues = xmlValues +"<ref_id><![CDATA[" + refId + "]]></ref_id>";
xmlValues = xmlValues +"<item_code><![CDATA[" + itemCode + "]]></item_code>";
xmlValues = xmlValues +"<tax_code><![CDATA[" + taxCode + "]]></tax_code>";
xmlValues = xmlValues +"<supp_code><![CDATA[" + suppCode + "]]></supp_code>";
xmlValues = xmlValues +"<tax_chap><![CDATA[" + taxChap + "]]></tax_chap>";
xmlValues = xmlValues +"<material_category><![CDATA[" + matCate+ "]]></material_category>";
// to generate sr_no based on any of the value.end
xmlValues = xmlValues +"</Detail1></Root>";
Statement stmt = null;
ResultSet rSet = null;
String keyStringQuery = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE TRAN_WINDOW = '" + winName +"' ";
stmt = con.createStatement();
rSet = stmt.executeQuery(keyStringQuery);
String tranSer = null;
String keyString = null;
String keyCol = null;
if(rSet.next())
{
keyString = rSet.getString("KEY_STRING");
keyCol = rSet.getString("TRAN_ID_COL");
tranSer = rSet.getString("REF_SER");
}
rSet.close();
rSet = null;
stmt.close();
stmt = null;
CommonConstants commonConstants = new CommonConstants();
TransIDGenerator tg = new TransIDGenerator(xmlValues, "BASE", commonConstants.DB_NAME);
uniqueKey = tg.generateTranSeqID(tranSer, keyCol, keyString, con);
System.out.println("Generated tran_id........" + uniqueKey);
}
catch(Exception e)
{
System.out.println("Exception : getUniqueKey :==>\n"+e);
uniqueKey = null;
throw new ITMException(e);
}
//System.out.println("Generated Primary Key :"+uniqueKey);
return uniqueKey;
}
}
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
@javax.ejb.Local
public interface CenvatCrCapitalPrcLocal extends ProcessLocal
{
public String process() throws RemoteException,ITMException;
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String getData(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
@javax.ejb.Remote
public interface CenvatCrCapitalPrcRemote extends ProcessRemote
{
public String process() throws RemoteException,ITMException;
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String getData(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException;
}
package ibase.webitm.ejb.dis;
import ibase.system.config.ConnDriver;
import ibase.utility.CommonConstants;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.MasterStatefulLocal;
import ibase.webitm.ejb.ProcessEJB;
import ibase.webitm.ejb.dis.DistCommon;
import ibase.webitm.ejb.dis.InvAllocTraceBean;
import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.Map;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
@javax.ejb.Stateless
public class PorcpProcessEJB extends ProcessEJB implements PorcpProcessLocal,PorcpProcessRemote
{
public String wfValData() throws RemoteException, ITMException
{
return "*********************STUDENT INFO****************************";
}
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
{
GenericUtility genericUtility = GenericUtility.getInstance();
System.out.println("==================YOGESHM==================");
String rtrStr = "";
Document headerDom = null;
Document detailDom = null;
System.out.println("getData(xmlString,xmlString2,windowName,xtraParams CALLED..."+ xmlString);
try
{
if(xmlString != null && xmlString.trim().length()!=0)
{
System.out.println("XML String :"+xmlString);
headerDom = genericUtility.parseString(xmlString);
}
if(xmlString2 != null && xmlString2.trim().length()!=0)
{
System.out.println("XML String :"+xmlString2);
detailDom = genericUtility.parseString(xmlString2);
}
rtrStr = getData(headerDom, detailDom, windowName, xtraParams);
}
catch (Exception e)
{
System.out.println("Exception :StockAllocationPrcEJB :getData(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
rtrStr = e.getMessage();
}
return rtrStr;
}
public String getData(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException
{
String siteCode="";
String tranId="";
String fromDate="";
String toDate="";
String errCode = "";
String errString = "";
PreparedStatement pstmt=null;
String getDataSql=null;
String resultString = "";
Connection conn = null;
ResultSet rs=null;
StringBuffer test=new StringBuffer();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
try
{
int count = 0;
NodeList parentList = null;
NodeList childList = null;
int noOfChilds = 0;
String childNodeName = "";
String sql = "";
Node childNode = null;
GenericUtility genericUtility = GenericUtility.getInstance();
ConnDriver connDriver = new ConnDriver();
SimpleDateFormat sdf;
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
String userId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" );
siteCode = genericUtility.getColumnValue("site_code",headerDom);
tranId = genericUtility.getColumnValue("tran_id",headerDom);
fromDate = genericUtility.getColumnValue("from_date",headerDom);
toDate= genericUtility.getColumnValue("to_date",headerDom);
System.out.println("headerDom:"+headerDom);
System.out.println("detailDom:"+detailDom);
System.out.println("windowName:"+windowName);
System.out.println("xtraParams:"+xtraParams);
if ( siteCode == null || siteCode.trim().length() == 0 )
{
errCode = "BLKSITECD";
errString = itmDBAccessEJB.getErrorString("","BLKSITECD",userId);
return errString;
}
else if(siteCode != null || siteCode.trim().length() != 0)
{
sql = " SELECT COUNT(*) FROM SITE WHERE SITE_CODE = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,siteCode);
rs = pstmt.executeQuery();
if(rs.next())
{
count = rs.getInt(1);
}
if(count == 0)
{
errCode = "INVSITECD";
errString = itmDBAccessEJB.getErrorString("","INVSITECD",userId);
return errString;
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
} //end of site_code
if ( tranId == null || tranId.trim().length() == 0 ) //tran_id
{
errCode = "BLKPRCHNO";
errString = itmDBAccessEJB.getErrorString("","BLKPRCHNO",userId);
return errString;
}
else if(tranId != null || tranId.trim().length() != 0)
{
sql = " SELECT COUNT(*) FROM PORCP WHERE TRAN_ID = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
count = rs.getInt(1);
}
if(count == 0)
{
errCode = "INVPRCHNO";
errString = itmDBAccessEJB.getErrorString("","INVPRCHNO",userId);
return errString;
}
else
{
siteCode = genericUtility.getColumnValue("site_code",headerDom);
tranId = genericUtility.getColumnValue("tran_id",headerDom);
sql=" SELECT COUNT(TRAN_ID) FROM PORCP WHERE SITE_CODE = ? AND TRAN_ID = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,siteCode);
pstmt.setString(2,tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
count = rs.getInt(1);
}
if(count == 0)
{
errCode = "INVPRCHNM";
errString = itmDBAccessEJB.getErrorString("","INVPRCHNM",userId);
return errString;
}
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
} //end of tran_id
getDataSql = " SELECT PORCP.TRAN_ID, PORCP.TRAN_DATE, PORCP.TRAN_TYPE, PORCP.SITE_CODE, PORCP.PURC_ORDER, PORCP.SUPP_CODE,"
+" PORCP.LR_NO, PORCP.LR_DATE FROM PORCP,SUPPLIER WHERE PORCP.SITE_CODE = ? AND PORCP.TRAN_ID = ? AND PORCP.SUPP_CODE = SUPPLIER.SUPP_CODE ";
pstmt = conn.prepareStatement(getDataSql);
pstmt.setString(1,siteCode);
pstmt.setString(2,tranId);
rs = pstmt.executeQuery();
while(rs.next())
{
test.append(rs.getString(1)).append("\t");
test.append(rs.getString(2)).append("\t");
test.append(rs.getString(3)).append("\t");
test.append(rs.getString(4)).append("\t");
test.append(rs.getString(5)).append("\t");
test.append(rs.getString(6)).append("\t");
test.append(rs.getString(7)).append("\t");
test.append(rs.getString(8)).append("\n");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
resultString=test.toString();
}
catch(Exception e)
{
System.out.println("Exception occured while getData()");
e.printStackTrace();
}
finally
{
try
{
if(conn != null)
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
conn.close();
}
conn = null;
}
catch(Exception ex)
{
System.out.println("Exception occured while getData()");
ex.printStackTrace();
}
}
return resultString;
} //get data method closed
public String wfValData(String currXmlDataStr, String hdrXmlDataStr, String allXmlDataStr, String objContext, String editFlag, String xtraParams) throws RemoteException, ITMException
{
return null;
}
public String wfValData(Document currDom, Document hdrDom, Document allDom, String objContext, String editFlag, String xtraParams) throws RemoteException, ITMException
{
return null;
}
public String itemChanged() throws RemoteException, ITMException
{
return "";
}
public String itemChanged(String currXmlDataStr, String hdrXmlDataStr, String allXmlDataStr, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException, ITMException
{
return null;
}
public String itemChanged( Document currDom, Document hdrDom, Document allDom, String objContext, String currentColumn, String editFlag, String xtraParams ) throws RemoteException,ITMException
{
return null;
}
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException
{
String retStr = "";
Document detailDom = null;
Document headerDom = null;
GenericUtility genericUtility = GenericUtility.getInstance();
System.out.println("*******************Testing Process Method**********************");
System.out.println("below genericUtility--------------->>>>>>>>>");
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 :StockAllocationPrcEJB :process(String xmlString, String xmlString2, String windowName, String xtraParams):" + e.getMessage() + ":");
e.printStackTrace();
retStr = e.getMessage();
throw new ITMException(e);
}
return retStr;
}
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException
{
Connection conn = null;
ResultSet rs = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
PreparedStatement pstmt = null;
String updateSql=null;
String sql=null;
String tranType = "";
String siteCode = "";
String tranId = "";
int parentNodeListLength = 0;
int childNodeListLength = 0;
NodeList parentNodeList = null;
String childNodeName = null;
int count = 0;
int tcnt= 0;
String errCode = "";
String errString = "";
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
try
{
String userId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" );
ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
connDriver = null;
conn.setAutoCommit(false);
System.out.println("headerDom:"+headerDom);
System.out.println("detailDom:"+detailDom);
System.out.println("windowName:"+windowName);
System.out.println("xtraParams:"+xtraParams);
parentNodeList = detailDom.getElementsByTagName("Detail2");
parentNodeListLength = parentNodeList.getLength();
for(int i=0; i<parentNodeListLength; i++)
{
parentNode = parentNodeList.item(i);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for (int childRow = 0; childRow < childNodeListLength; childRow++)
{
System.out.println("ABC********");
childNode = childNodeList.item(childRow);
childNodeName = childNode.getNodeName();
System.out.println("childNodeName ="+childNodeName);
if (childNodeName.equals("tran_type"))
{
if(childNode.getFirstChild()!=null)
{
tranType = (childNode.getFirstChild().getNodeValue()).trim();
System.out.println("************=tranType"+tranType);
}
if(tranType.trim().length() == 0)
{
errCode = "BLKTRNTYP";
errString = itmDBAccessEJB.getErrorString("","BLKTRNTYP",userId);
return errString;
}
else if (tranType != null || tranType.trim().length() != 0)
{
System.out.println("************ELSE IF=tranType"+tranType);
System.out.println("************TRANTYPELENGTH="+tranType.trim().length());
sql = " SELECT COUNT(*) FROM GENCODES WHERE FLD_NAME ='TRAN_TYPE' AND MOD_NAME = 'W_PORCP' AND FLD_VALUE = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,tranType);
rs = pstmt.executeQuery();
if(rs.next())
{
count = rs.getInt(1);
}
if(count == 0)
{
errCode = "INVTRNTYP";
errString = itmDBAccessEJB.getErrorString("","INVTRNTYP",userId);
return errString;
}
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
//end of tran_id
}
if(childNodeName.equals("tran_id"))
{
if(childNode.getFirstChild()!=null)
{
tranId=(childNode.getFirstChild().getNodeValue().trim());
System.out.println("*************=tranId"+tranId);
}
}
if(childNodeName.equals("site_code"))
{
if(childNode.getFirstChild()!=null)
{
siteCode=(childNode.getFirstChild().getNodeValue().trim());
System.out.println("*************=siteCode"+siteCode);
}
}
updateSql= " UPDATE PORCP SET TRAN_TYPE = ? WHERE TRAN_ID= ? AND SITE_CODE = ? ";
pstmt = conn.prepareStatement(updateSql);
pstmt.setString(1,tranType);
pstmt.setString(2,tranId);
pstmt.setString(3,siteCode);
count = pstmt.executeUpdate();
conn.commit();
}
tcnt++;
}
if(tcnt > 0)
{
System.out.println("******Updated Rows Count="+tcnt);
errCode = "PRCESSFUL";
errString = itmDBAccessEJB.getErrorString("","PRCESSFUL",userId);
}
}
catch (Exception e)
{
System.out.println(e.getMessage());
}
finally
{
try
{
if(conn != null)
{
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
conn.close();
}
conn = null;
}
catch (Exception ex)
{
ex.printStackTrace();
System.out.println("************HELLO");
}
}
return errString;
} //process method
private String checkNull( String input )
{
if( input == null )
{
input = "";
}
else
{
input = input.trim();
}
return input;
}
} // class closed
package ibase.webitm.ejb.dis;
import ibase.webitm.ejb.ProcessLocal;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import org.w3c.dom.Document;
@javax.ejb.Local
public interface PorcpProcessLocal extends ProcessLocal
{
public String wfValData() throws RemoteException,ITMException;
public String wfValData( String xmlString_, String xmlString1,String xmlString2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String wfValData( Document dom_, Document dom1,Document dom2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged() throws RemoteException,ITMException;
public String itemChanged(String xmlString_, String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String itemChanged(Document dom_, Document dom1, Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String getData(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import org.w3c.dom.*;
import ibase.webitm.ejb.*;
import ibase.webitm.utility.ITMException;
@javax.ejb.Remote
public interface PorcpProcessRemote extends ProcessRemote
{
public String wfValData() throws RemoteException,ITMException;
public String wfValData(String xmlString_, String xmlString1,String xmlString2, String objContext, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String wfValData(Document dom_,Document dom1,Document dom2,String objContext,String editFlag,String xtraParams) throws RemoteException,ITMException;
public String itemChanged() throws RemoteException,ITMException;
public String itemChanged(String xmlString_, String xmlString1,String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
// public String itemChanged(Document dom_, Document dom1, Document dom2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException,ITMException;
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String getData(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException,ITMException;
}
\ No newline at end of file
This source diff could not be displayed because it is too large. You can view the blob instead.
......@@ -8,7 +8,6 @@ import org.w3c.dom.*;
import javax.xml.parsers.*;
import javax.ejb.*;
import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.*;
import ibase.system.config.*;
import ibase.webitm.ejb.*;
......@@ -228,6 +227,15 @@ public class TaxSchIc extends ValidatorEJB implements TaxSchIcLocal, TaxSchIcRem
int ctr = 0;
int currentFormNo = 0;
String errCode = "";
//Changed by Rohan on 13-03-13 for define variables.start
String batchPart1 = "";
String batchPart2 = "";
String batchPart3 = "";
String batchPart4 = "";
String batchPartStr = "";
int batchPartInt = 0;
int remChar = 0;
//Changed by Rohan on 13-03-13 for define variables.end
java.sql.PreparedStatement pstmt=null;
java.sql.ResultSet rs = null;
StringBuffer valueXmlString = new StringBuffer();
......@@ -246,6 +254,14 @@ public class TaxSchIc extends ValidatorEJB implements TaxSchIcLocal, TaxSchIcRem
String finEnt =null;
String trandateToTsStr=null;
String trandateFromTsStr=null;
//Changed by Rohna on 19-03-13 for define variable.start
String processDateStr = null;
java.sql.Timestamp processDate = null;
java.sql.Timestamp trandateToTs=null;
java.sql.Timestamp trandateFromTS=null;
String batchNoStr=null;
String procDate = "";
//Changed by Rohna on 19-03-13 for define variable.end
double cloBal=0;
String sCloBal = null;
String siteCode=null;
......@@ -470,9 +486,7 @@ public class TaxSchIc extends ValidatorEJB implements TaxSchIcLocal, TaxSchIcRem
else
{
java.sql.Timestamp trandateToTs=null;
java.sql.Timestamp trandateFromTS=null;
String batchNoStr=null;
//String trandateTo =null;
//String trandateFrom=null;
//From Filter
......@@ -480,8 +494,8 @@ public class TaxSchIc extends ValidatorEJB implements TaxSchIcLocal, TaxSchIcRem
trandateFrom = getColumnValue("tran_date__from",dom);
System.out.println("tran_date__to(APPL)::["+trandateTo+"]");
System.out.println("tran_date__from(APPL)::["+trandateFrom+"]");
System.out.println("DrCr Type in else :: " + currentColumn);
siteCode = getColumnValue("site_code",dom);
System.out.println("DrCr Type in else :: " + currentColumn+"siteCode:::"+siteCode);
//converting to dbdate format
trandateToTsStr = genericUtility.getValidDateString(trandateTo,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat());
trandateFromTsStr = genericUtility.getValidDateString(trandateTo,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat());
......@@ -490,22 +504,33 @@ public class TaxSchIc extends ValidatorEJB implements TaxSchIcLocal, TaxSchIcRem
//convert timestring to timestamp object
//Changed by Rohan on 19-03-13 for check finantial period depending on process date.start
/*
trandateToTs = Timestamp.valueOf(trandateToTsStr+" 00:00:00");
trandateFromTS = Timestamp.valueOf(trandateToTsStr+" 00:00:00");
System.out.println("Tran Date(DB) ::["+trandateToTs+"]");
System.out.println("Tran Date(DB) ::["+trandateFromTS+"]");
*/
//Changed by Rohan on 19-03-13 for check finantial period depending on process date.end
//calculating the trandate from and to from account perion table
//Changed by Rohan on 19-03-13 for check finantial period depending on process date.start
/*
sql ="select fr_date,to_date from acctprd where ? >= fr_date and ?<=to_date";
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1,trandateFromTS);
pstmt.setTimestamp(2,trandateToTs);
*/
procDate = getColumnValue("proc_date",dom);
System.out.println("Processing Date"+procDate);
processDateStr = genericUtility.getValidDateString(procDate,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat());
processDate = Timestamp.valueOf(processDateStr+" 00:00:00");
sql ="select fr_date,to_date from acctprd where ? between fr_date and to_date ";
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1,processDate);
//Changed by Rohan on 19-03-13 for check finantial period depending on process date.end
rs = pstmt.executeQuery();
System.out.println("Query Executed::::::::::"+sql);
System.out.println("Setting Parameter ::["+trandateFromTS+"]");
System.out.println("Setting Parameter ::["+trandateToTs+"]");
if(rs.next())
{
trandateFromTS = rs.getTimestamp(1);;
......@@ -542,15 +567,69 @@ public class TaxSchIc extends ValidatorEJB implements TaxSchIcLocal, TaxSchIcRem
System.out.println("Setting Parameter ::["+trandateToTs+"]");
System.out.println("batchNoStr::["+batchNoStr+"]");
//Changed by Rohan on 13-03-13 for generating automatic batch number.start
sql ="SELECT DOC_PREFIX FROM SITE WHERE SITE_CODE = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,siteCode);
rs = pstmt.executeQuery();
if(rs.next())
{
batchPart1 = rs.getString("DOC_PREFIX");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
batchPart2 = String.valueOf(trandateToTs).substring(2,4);
if(batchNoStr != null && batchNoStr.trim().length() > 0)
{
if(batchNoStr.trim().length() == 10)
{
batchPart4 = batchNoStr.substring(5,10);
}
else
{
batchPart4 = "0";
}
}
else
{
batchPart4 = "0";
}
batchPartInt = Integer.parseInt(batchPart4) + 1;
batchPart4 = String.valueOf(batchPartInt);
remChar = 10 - (batchPart1+batchPart2+batchPart4).trim().length();
for(int i = 0;i < remChar ; i++)
{
batchPart3 = batchPart3.concat("0");
}
System.out.println("batchPart1"+batchPart1+"batchPart2"+batchPart2+"batchPart3"+batchPart3+"batchPart4"+batchPart4);
batchNoStr = batchPart1+batchPart2+batchPart3+batchPart4;
System.out.println("batchNoStr---->"+batchNoStr);
//Changed by Rohan on 13-03-13 for generating automatic batch number.end
valueXmlString.append("<bal_group__adj protect=\"0\">").append(" ").append("</bal_group__adj>\r\n");
valueXmlString.append("<adj_amt protect=\"0\">").append(" ").append("</adj_amt>\r\n");
valueXmlString.append("<adj_amt>").append("0.0").append("</adj_amt>\r\n");
// by msalam on 19/06/07 for req Id :: DI78SUN049
//If batchNoStr is coming null from database the put blank else put it as it is.
if(batchNoStr == null || batchNoStr.length() == 0)
valueXmlString.append("<batch_no protect=\"0\">").append(" ").append("</batch_no>\r\n");
//Changed by Rohan on 13-02-13 for making batch no feild not editable & automatic
//valueXmlString.append("<batch_no protect=\"0\">").append(" ").append("</batch_no>\r\n");
valueXmlString.append("<batch_no protect=\"1\">").append(" ").append("</batch_no>\r\n");
else
valueXmlString.append("<batch_no protect=\"0\">").append(batchNoStr).append("</batch_no>\r\n");
//Changed by Rohan on 13-02-13 for making batch no feild not editable & automatic
//valueXmlString.append("<batch_no protect=\"0\">").append(batchNoStr).append("</batch_no>\r\n");
valueXmlString.append("<batch_no protect=\"1\">").append(batchNoStr).append("</batch_no>\r\n");
}
}
......
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