Skip to content

W
webitm-sfa-reports
Commit 8e775d5b authored by Ketan Patil's avatar Ketan Patil
Browse files
Options

Deleted SalesConsolidationRuleIC.java, SalesConsolidationRuleICLocal.java,... 

Deleted SalesConsolidationRuleIC.java, SalesConsolidationRuleICLocal.java, SalesConsolidationRuleICRemote.java, SalesConsolidationRulePrc.java, SalesConsolidationRulePrcLocal.java, SalesConsolidationRulePrcRemote.java files
parent 973736ab
Hide whitespace changes
Inline Side-by-side
Showing with 0 additions and 3232 deletions
SalesConsolidationRuleIC.java deleted 100644 → 0
View file @ 973736ab
/***
* Author:Santosh
* Date:24-APR-2019
*/
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Calendar;
import javax.ejb.Stateless;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import ibase.system.config.ConnDriver;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.ITMException;
@Stateless
public class SalesConsolidationRuleIC extends ValidatorEJB implements SalesConsolidationRuleICLocal , SalesConsolidationRuleICRemote
{
public String wfValData(String currFrmXmlStr, String hdrFrmXmlStr,String allFrmXmlStr, String objContext, String editFlag,String xtraParams) throws RemoteException
{
System.out.println("In PriSecSalesConsolidationIC wfValData");
Document currDom = null;
Document hdrDom = null;
Document allDom = null;
String errString = "";
try
{
System.out.println("currFrmXmlStr..." + currFrmXmlStr);
System.out.println("hdrFrmXmlStr..." + hdrFrmXmlStr);
System.out.println("allFrmXmlStr..." + allFrmXmlStr);
if ((currFrmXmlStr != null) && (currFrmXmlStr.trim().length() != 0))
{
currDom = parseString(currFrmXmlStr);
}
if ((hdrFrmXmlStr != null) && (hdrFrmXmlStr.trim().length() != 0))
{
hdrDom = parseString(hdrFrmXmlStr);
}
if ((allFrmXmlStr != null) && (allFrmXmlStr.trim().length() != 0))
{
allDom = parseString(allFrmXmlStr);
}
errString = wfValData(currDom, hdrDom, allDom, objContext, editFlag, xtraParams);
}
catch (Exception e)
{
System.out.println("Exception : [PriSecSalesConsolidationIC][wfValData(String currFrmXmlStr)] : ==>\n" + e.getMessage());
}
return errString;
}
public String wfValData(Document currDom, Document hdrDom, Document allDom,String objContext, String editFlag, String xtraParams)throws RemoteException, ITMException
{
E12GenericUtility genericUtility= new E12GenericUtility();
String errString = "" , loginSiteCode = "" , userId ="" , isPrdClosed = "",overWrite="" ;
String childNodeName = "";
String sql = "";
int noOfChilds = 0;
ResultSet rs = null;
Connection conn = null;
PreparedStatement pstmt = null;
int currentFormNo = 0;
int cnt = 0,count=0,unConfCnt=0,excnt=0;
ConnDriver connDriver = null;
Node childNode = null;
String itemSer="" , prdCode = "" ,maxPrdCode="" ,countryCode="", accPeriod="" ,versionId="",prdCodeFrm="",prdCodeTo="";
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
try {
System.out.println("************xtraParams*************" + xtraParams);
connDriver = new ConnDriver();
/* conn = connDriver.getConnectDB("DriverITM"); */
conn = getConnection();
System.out.println("In wfValData PriSecSalesConsolidationIC :::");
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
loginSiteCode = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginSiteCode"));
System.out.println("**************loginCode************" + userId);
if ((objContext != null) && (objContext.trim().length() > 0))
{
currentFormNo = Integer.parseInt(objContext);
}
NodeList parentList = currDom.getElementsByTagName("Detail"+ currentFormNo);
NodeList childList = null;
System.out.println("hdrDom..." + hdrDom.toString());
switch (currentFormNo)
{
case 1:
{
childList = parentList.item(0).getChildNodes();
noOfChilds = childList.getLength();
for (int ctr = 0; ctr < noOfChilds; ctr++)
{
childNode = childList.item(ctr);
if (childNode.getNodeType() != 1)
{
continue;
}
childNodeName = childNode.getNodeName();
System.out.println("Editflag =" + editFlag);
System.out.println("parentList = " + parentList);
System.out.println("childList = " + childList);
if ("item_ser".equalsIgnoreCase(childNodeName))
{
itemSer = genericUtility.getColumnValue("item_ser", currDom);
System.out.println("wfValData>>itemSer>>"+itemSer);
if(itemSer == null || itemSer.trim().length()==0 )
{
errString = itmDBAccessEJB.getErrorString("item_ser","VMNULLDIV",userId);
break;
}
else
{
sql = "SELECT COUNT(*) AS COUNT FROM ITEMSER WHERE ITEM_SER = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemSer);
rs = pstmt.executeQuery();
if (rs.next())
{
count = rs.getInt("COUNT");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("Count: " + count);
if (count == 0)
{
errString = itmDBAccessEJB.getErrorString("item_ser","VTINVDIV",userId);
break;
}
}
}
else if ("acct_prd".equalsIgnoreCase(childNodeName))
{
accPeriod = checkNull(genericUtility.getColumnValue("acct_prd", currDom));
prdCodeFrm = checkNull(genericUtility.getColumnValue("prd_code_from", currDom));
prdCodeTo = checkNull(genericUtility.getColumnValue("prd_code_to", currDom));
String prdCodeFrmStr="",prdCodeToStr="";
System.out.println("wfValData>>accPeriod>>"+accPeriod);
if(accPeriod == null || accPeriod.trim().length()==0 )
{
errString = itmDBAccessEJB.getErrorString("acc_prd","VTACCTBLNK",userId);
break;
}
else
{
sql = "SELECT COUNT(*) AS COUNT FROM acctprd WHERE code = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, accPeriod);
rs = pstmt.executeQuery();
if (rs.next())
{
count = rs.getInt("COUNT");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("Count: " + count);
if (count == 0)
{
errString = itmDBAccessEJB.getErrorString("acct_prd","VTINVACCT",userId);
break;
}
if ((prdCodeFrm!=null && prdCodeFrm.trim().length()>0) && (prdCodeTo!=null && prdCodeTo.trim().length()>0))
{
sql="select min(p.code)as prd_code_from,max(p.code) as prd_code_to from period p ,acctprd a where p.acct_prd=a.code and p.acct_prd =? order by p.code";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,accPeriod.trim());
rs = pstmt.executeQuery();
if(rs.next())
{
prdCodeFrmStr=checkNull(rs.getString(1));
prdCodeToStr=checkNull(rs.getString(2));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
/*if (!prdCodeFrmStr.equalsIgnoreCase(prdCodeFrm) || !prdCodeToStr.equalsIgnoreCase(prdCodeTo))
{
errString = itmDBAccessEJB.getErrorString("acct_prd","VTINVACPD",userId);
break;
}*/
}
}
}
else if ("version_id".equalsIgnoreCase(childNodeName))
{
versionId = checkNull(genericUtility.getColumnValue("version_id", currDom));
System.out.println("wfValData>>versionId>>"+versionId);
if(versionId==null || versionId.trim().length()==0)
{
errString = itmDBAccessEJB.getErrorString("version_id","VTVERSBLNK",userId);
break;
}
else
{
sql = " SELECT COUNT(*) AS COUNT FROM version WHERE version_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, versionId);
// pstmt.setString(2, itemSer);
rs = pstmt.executeQuery();
if(rs.next())
{
count = rs.getInt("COUNT");
}
if(count == 0)
{
errString = itmDBAccessEJB.getErrorString("versionId","VTNINVVERS",userId);
break ;
}
}
}
/**
* Condition added to check if already data is present then overwrite it */
else if ("overwrite".equalsIgnoreCase(childNodeName))
{
overWrite = genericUtility.getColumnValue("overwrite", currDom);
prdCodeFrm = genericUtility.getColumnValue("prd_code_from", currDom);
prdCodeTo = genericUtility.getColumnValue("prd_code_to", currDom);
System.out.println("wfValData>>overWrite>>"+overWrite);
if("N".equalsIgnoreCase(overWrite))
{
sql="select count(distinct cal_month) as count from SALES_CONS_RULEWISE where cal_month between ? and ? AND ITEM_SER = ? ";
//sql = " SELECT COUNT(*) AS COUNT FROM SALES_CONS_RULEWISE WHERE version_id = ? AND ITEM_SER=?";
pstmt = conn.prepareStatement(sql);
//pstmt.setString(1, versionId);
pstmt.setString(1,prdCodeFrm);
pstmt.setString(2, prdCodeTo);
pstmt.setString(3, itemSer);
rs = pstmt.executeQuery();
if(rs.next())
{
count = rs.getInt("COUNT");
}
if(count > 0)
{
errString = itmDBAccessEJB.getErrorString("overwrite","VTDATA",userId);
break ;
}
}
}
else if ("prd_code_from".equalsIgnoreCase(childNodeName))
{
prdCodeFrm = genericUtility.getColumnValue("prd_code_from", currDom);
itemSer = genericUtility.getColumnValue("item_ser", currDom);
sql= "select count_code from state where " +
"state_code in (select state_code from site where site_code=?)";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, loginSiteCode );
rs = pstmt.executeQuery();
if(rs.next())
{
countryCode = checkNull(rs.getString("count_code")).trim();
System.out.println("countryCode >>> :"+countryCode);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("wfValData>>prdCodeFrm>>"+prdCodeFrm+">>itemSer"+itemSer);
/*if(prdCodeFrm == null || prdCodeFrm.trim().length() == 0)
{
errString = itmDBAccessEJB.getErrorString("prd_code_from","VTPRDFRBLK",userId);
break ;
}
else
{
sql = " SELECT COUNT(*) FROM PERIOD A , PERIOD_TBL B WHERE A.CODE = B.PRD_CODE AND B.PRD_CODE = ? and B.PRD_TBLNO= ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,prdCodeFrm);
pstmt.setString(2,countryCode+"_"+itemSer.trim());
rs = pstmt.executeQuery();
if (rs.next())
{
cnt = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if (cnt == 0)
{
System.out.println("Error :Period not exist in period_tbl master ");
errString = itmDBAccessEJB.getErrorString("","VTINVPRDFR",userId);
break ;
}
else
{
sql = "SELECT B.PRD_CLOSED FROM PERIOD A , PERIOD_TBL B WHERE A.CODE = B.PRD_CODE AND B.PRD_CODE = ? and B.PRD_TBLNO= ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,prdCodeFrm.trim());
pstmt.setString(2,countryCode+"_"+itemSer.trim());
rs = pstmt.executeQuery();
if(rs.next())
{
isPrdClosed = rs.getString("PRD_CLOSED");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if("N".equalsIgnoreCase(isPrdClosed))
{
errString = itmDBAccessEJB.getErrorString("","VTPRDFRMOP",userId);
break ;
}
}
}*/
}
else if ("prd_code_to".equalsIgnoreCase(childNodeName))
{
prdCodeTo = genericUtility.getColumnValue("prd_code_to", currDom);
itemSer = genericUtility.getColumnValue("item_ser", currDom);
sql= "select count_code from state where " +
"state_code in (select state_code from site where site_code=?)";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, loginSiteCode );
rs = pstmt.executeQuery();
if(rs.next())
{
countryCode = checkNull(rs.getString("count_code")).trim();
System.out.println("countryCode >>> :"+countryCode);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("wfValData>>prdCodeTo>>"+prdCodeTo+">>itemSer"+itemSer);
/*if(prdCodeTo == null || prdCodeTo.trim().length() == 0)
{
errString = itmDBAccessEJB.getErrorString("prd_code_to","VTPRDTOBLK",userId);
break ;
}
else
{
sql = " SELECT COUNT(*) FROM PERIOD A , PERIOD_TBL B WHERE A.CODE = B.PRD_CODE AND B.PRD_CODE = ? and B.PRD_TBLNO= ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,prdCodeTo);
pstmt.setString(2,countryCode+"_"+itemSer.trim());
rs = pstmt.executeQuery();
if (rs.next())
{
cnt = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if (cnt == 0)
{
System.out.println("Error :Period not exist in period_tbl master ");
errString = itmDBAccessEJB.getErrorString("","VTINVPRDTO",userId);
break ;
}
else
{
sql = "SELECT B.PRD_CLOSED FROM PERIOD A , PERIOD_TBL B WHERE A.CODE = B.PRD_CODE AND B.PRD_CODE = ? and B.PRD_TBLNO= ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,prdCodeTo.trim());
pstmt.setString(2,countryCode+"_"+itemSer.trim());
rs = pstmt.executeQuery();
if(rs.next())
{
isPrdClosed = rs.getString("PRD_CLOSED");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if("N".equalsIgnoreCase(isPrdClosed))
{
errString = itmDBAccessEJB.getErrorString("","VTPRDTOMOP",userId);
break ;
}
}
}*/
}
/**
*Commented by santosh to take prd_code_frm and prd_code_to
else if ("prd_code".equalsIgnoreCase(childNodeName))
{
prdCode = genericUtility.getColumnValue("prd_code", currDom);
itemSer = genericUtility.getColumnValue("item_ser", currDom);
sql= "select count_code from state where " +
"state_code in (select state_code from site where site_code=?)";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, loginSiteCode );
rs = pstmt.executeQuery();
if(rs.next())
{
countryCode = checkNull(rs.getString("count_code")).trim();
System.out.println("countryCode >>> :"+countryCode);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("wfValData>>prdCodeFrm>>"+prdCodeFrm+">>itemSer"+itemSer);
if(prdCodeFrm == null || prdCodeFrm.trim().length() == 0)
{
errString = itmDBAccessEJB.getErrorString("prd_code_from","VMNULLPRD ",userId);
break ;
}
else
{
sql = " SELECT COUNT(*) FROM PERIOD A , PERIOD_TBL B WHERE A.CODE = B.PRD_CODE AND B.PRD_CODE = ? and B.PRD_TBLNO= ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,prdCode);
pstmt.setString(2,countryCode+"_"+itemSer.trim());
rs = pstmt.executeQuery();
if (rs.next())
{
cnt = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if (cnt == 0)
{
System.out.println("Error :Period not exist in period_tbl master ");
errString = itmDBAccessEJB.getErrorString("","VMINVPRDTB",userId);
break ;
}
else
{
sql = "SELECT B.PRD_CLOSED FROM PERIOD A , PERIOD_TBL B WHERE A.CODE = B.PRD_CODE AND B.PRD_CODE = ? and B.PRD_TBLNO= ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,prdCode.trim());
pstmt.setString(2,countryCode+"_"+itemSer.trim());
rs = pstmt.executeQuery();
if(rs.next())
{
isPrdClosed = rs.getString("PRD_CLOSED");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if("N".equalsIgnoreCase(isPrdClosed))
{
errString = itmDBAccessEJB.getErrorString("","VMPRDNCL",userId);
break ;
}
else
{
sql="select max(prd_code) from period_tbl where PRD_TBLNO=? and PRD_CLOSED='Y' ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,countryCode+"_"+itemSer.trim());
rs = pstmt.executeQuery();
if(rs.next())
{
maxPrdCode = rs.getString(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(!prdCode.equalsIgnoreCase(maxPrdCode))
{
//max period check
errString = itmDBAccessEJB.getErrorString("","VTINVPCD",userId);
break ;
}
else
{/**
Commented By Santosh On 24-APR-2019
If Secondary Data is Directly Fetch From ES3[Cust_stock,cust_sttock_det,cust_stock_inv] Table Then
this code will be make as uncommented so to validate only confirm transaction
sql = " SELECT COUNT(*) AS COUNT FROM CUST_STOCK A JOIN CUST_STOCK_DET B ON A.TRAN_ID = B.TRAN_ID " +
" JOIN CUSTOMER D ON D.CUST_CODE = A.CUST_CODE WHERE A.PRD_CODE = ? and A.ITEM_SER=? " ;
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, prdCode);
pstmt.setString(2,itemSer);
rs = pstmt.executeQuery();
if(rs.next())
{
excnt = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if (excnt >= 0)
{
sql = "SELECT COUNT(*) AS COUNT FROM CUST_STOCK WHERE PRD_CODE = ? AND ITEM_SER=? AND STATUS='O' AND CONFIRMED='N'" ;
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, prdCode);
pstmt.setString(2,itemSer);
rs = pstmt.executeQuery();
if(rs.next())
{
unConfCnt = rs.getInt(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(unConfCnt>0)
{
System.out.println("Unconfirmed records found ");
errString = itmDBAccessEJB.getErrorString("","VTINVRCD",userId);
break ;
}
}
else
{
System.out.println("No record found ");
errString = itmDBAccessEJB.getErrorString("","VTNULLRCD",userId);
break ;
}
}
}
}
}
}**/
}
}
break;
}
}
catch (Exception e)
{
System.out.println("Exception in "+this.getClass().getSimpleName()+" == >");
e.printStackTrace();
throw new ITMException(e);
}
finally
{
try
{
if (rs != null)
{
rs.close();
rs = null;
}
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if ((conn != null) && (!conn.isClosed()))
conn.close();
}
catch (Exception e)
{
System.out.println("Exception :"+this.getClass().getSimpleName()+":wfValData :==>\n" + e.getMessage());
throw new ITMException(e);
}
}
return errString;
}
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 = "";
System.out.println("XmlString :::::::::: "+xmlString);
System.out.println("XmlString1 :::::::::: "+xmlString1);
System.out.println("XmlString2 :::::::::: "+xmlString2);
try
{
if (xmlString != null && xmlString.trim().length() > 0)
{
dom = parseString(xmlString);
System.out.println("Dom ::::::: "+dom);
}
if (xmlString1 != null && xmlString1.trim().length() > 0) {
dom1 = parseString(xmlString1);
System.out.println("Dom1 ::::::: "+dom1);
}
if (xmlString2 != null && xmlString2.trim().length() > 0) {
dom2 = parseString(xmlString2);
System.out.println("Dom2 ::::::: "+dom2);
}
valueXmlString = itemChanged(dom, dom1, dom2, objContext,currentColumn, editFlag, xtraParams);
} catch (Exception e) {
System.out.println("Exception : [PriSecSalesConsolidationIC] :==>\n"+ e.getMessage());
throw new ITMException(e);
}
return valueXmlString;
}
public String itemChanged(Document currDom, Document hdrDom, Document allDom,String objContext, String currentColumn, String editFlag,String xtraParams) throws RemoteException, ITMException
{
E12GenericUtility genericUtility= new E12GenericUtility();
int currentFormNo = 0;
StringBuffer valueXmlString = null;
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
String childNodeName = null, columnValue = "",maxPrdCode="",itemSer="",sql="",countryCode="",loginSiteCode="",accPeriod="",prdCodeFrm="",prdCodeTo="";
int ctr = 0, childNodeListLength = 0 ;
ResultSet rs = null;
PreparedStatement pstmt = null;
Connection conn = null;
ConnDriver connDriver = null;
try
{
if (objContext != null && objContext.trim().length() > 0) {
currentFormNo = Integer.parseInt(objContext);
}
currentColumn = checkNull(currentColumn);
connDriver = new ConnDriver();
/* conn = connDriver.getConnectDB("DriverITM"); */
conn = getConnection();
valueXmlString = new StringBuffer("<?xml version=\"1.0\"?><Root><header><editFlag>");
valueXmlString.append(editFlag).append("</editFlag></header>");
loginSiteCode = checkNull(genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginSiteCode"));
switch (currentFormNo)
{
case 1:
{
System.out.println("Inside Case 1 Of Itemchange");
parentNodeList = currDom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
valueXmlString.append("<Detail1>");
childNodeListLength = childNodeList.getLength();
do
{
childNode = childNodeList.item(ctr);
childNodeName = childNode.getNodeName();
ctr++;
}while ((ctr < childNodeListLength) && (!childNodeName.equals(currentColumn)));
System.out.println(" currentColumn : "+ currentColumn);
System.out.println("current form::::::::::::" + currentFormNo);
if ( "itm_default".equalsIgnoreCase(currentColumn))
{
valueXmlString.append("<prd_code_from>").append("").append("</prd_code_from>");
valueXmlString.append("<prd_code_to>").append("").append("</prd_code_to>");
valueXmlString.append("<acct_prd>").append("").append("</acct_prd>");
valueXmlString.append("<item_ser>").append("").append("</item_ser>");
valueXmlString.append("<version_id>").append("").append("</version_id>");
valueXmlString.append("<overwrite>").append("<![CDATA[N]]>").append("</overwrite>");
}
else if ("acct_prd".equalsIgnoreCase(currentColumn))
{
accPeriod = checkNull(genericUtility.getColumnValue("acct_prd", currDom));
System.out.println("accPeriod>>>"+accPeriod);
sql="select min(p.code)as prd_code_from,max(p.code) as prd_code_to from period p ,acctprd a where p.acct_prd=a.code and p.acct_prd =? order by p.code";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,accPeriod.trim());
rs = pstmt.executeQuery();
if(rs.next())
{
prdCodeFrm=checkNull(rs.getString(1));
prdCodeTo=checkNull(rs.getString(2));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(prdCodeFrm.length()>0 && prdCodeTo.length()>0 )
{
valueXmlString.append("<prd_code_from>").append("<![CDATA[" + prdCodeFrm + "]]>").append("</prd_code_from>");
valueXmlString.append("<prd_code_to>").append("<![CDATA[" + prdCodeTo + "]]>").append("</prd_code_to>");
}
else
{
valueXmlString.append("<prd_code_from>").append("<![CDATA[]]>").append("</prd_code_from>");
valueXmlString.append("<prd_code_to>").append("<![CDATA[]]>").append("</prd_code_to>");
}
}
/**
* Commented by santosh on 09-MAY-2019 to item changes on the bases of acct_prd
* else if ("item_ser".equalsIgnoreCase(currentColumn))
{
itemSer = checkNull(genericUtility.getColumnValue("item_ser", currDom));
System.out.println("itemSer>>>"+itemSer);
if(itemSer.trim().length()>0){
sql= "select count_code from state where " +
"state_code in (select state_code from site where site_code=?)";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, loginSiteCode );
rs = pstmt.executeQuery();
if(rs.next())
{
countryCode = checkNull(rs.getString("count_code")).trim();
System.out.println("countryCode >>> :"+countryCode);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
sql="select max(prd_code) from period_tbl where PRD_TBLNO=? and PRD_CLOSED='Y' ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,countryCode+"_"+itemSer.trim());
rs = pstmt.executeQuery();
if(rs.next())
{
maxPrdCode = checkNull(rs.getString(1));
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(maxPrdCode.length()>0)
{
valueXmlString.append("<prd_code>").append("<![CDATA[" + maxPrdCode + "]]>").append("</prd_code>");
}
else
{
valueXmlString.append("<prd_code>").append("<![CDATA[]]>").append("</prd_code>");
}
}
else
{
valueXmlString.append("<prd_code>").append("<![CDATA[]]>").append("</prd_code>");
}
}*/
valueXmlString.append("</Detail1>\r\n");
}
break;
}
}
catch (Exception e)
{
try
{
e.printStackTrace();
throw new ITMException(e);
}
catch (Exception ex)
{
ex.printStackTrace();
throw new ITMException(ex);
}
}
finally
{
try {
if (conn != null) {
conn.close();
conn = null;
}
if(rs != null )
{
rs.close();
rs = null;
}
if (pstmt != null) {
pstmt.close();
pstmt = null;
}
} catch (Exception e) {
e.printStackTrace();
throw new ITMException(e);
}
}
valueXmlString.append("</Root>\r\n");
return valueXmlString.toString();
}
private String checkNull(String input)
{
return input == null ? "" : input.trim();
}
}
SalesConsolidationRuleICLocal.java deleted 100644 → 0
View file @ 973736ab
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import ibase.webitm.ejb.ValidatorLocal;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local;
import org.w3c.dom.Document;
@Local
public interface SalesConsolidationRuleICLocal extends ValidatorLocal
{
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(String xmlString, String xmlString1,String xmlString2, 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;
}
SalesConsolidationRuleICRemote.java deleted 100644 → 0
View file @ 973736ab
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import ibase.webitm.ejb.ValidatorRemote;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote;
import org.w3c.dom.Document;
@Remote
public interface SalesConsolidationRuleICRemote extends ValidatorRemote
{
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(String xmlString, String xmlString1,String xmlString2, 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;
}
SalesConsolidationRulePrc.java deleted 100644 → 0
View file @ 973736ab
This source diff could not be displayed because it is too large. You can view the blob instead.
SalesConsolidationRulePrcLocal.java deleted 100644 → 0
View file @ 973736ab
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import ibase.webitm.ejb.ProcessLocal;
import ibase.webitm.utility.ITMException;
import javax.ejb.Local;
import org.w3c.dom.Document;
@Local
public interface SalesConsolidationRulePrcLocal extends ProcessLocal {
public String process(Document dom, Document dom2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException,ITMException;
}
SalesConsolidationRulePrcRemote.java deleted 100644 → 0
View file @ 973736ab
package ibase.webitm.ejb.dis;
import java.rmi.RemoteException;
import ibase.webitm.ejb.ProcessRemote;
import ibase.webitm.utility.ITMException;
import javax.ejb.Remote;
import org.w3c.dom.Document;
@Remote
public interface SalesConsolidationRulePrcRemote extends ProcessRemote{
public String process(Document dom, Document dom2, String windowName, String xtraParams) throws RemoteException,ITMException;
public String process(String xmlString, String xmlString2, String windowName, 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