Commit 06c4f33b authored by prane's avatar prane

changes to update column conf_passwd and channel_partner flag and confirm on...

changes to update column  conf_passwd and channel_partner flag and confirm on passwd process in porcp, despatch and sreturn and new componenets .

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@202098 ce508802-f39f-4f6c-b175-0d175dae99d5
parent e8128eea
......@@ -5,7 +5,7 @@ import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.fin.FinCommon;
import ibase.webitm.utility.ITMException;
import ibase.utility.BaseLogger;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
......@@ -3283,7 +3283,7 @@ public class DispatchIC extends ValidatorEJB implements DispatchICLocal,Dispatch
int childNodeListLength1=0,curlineno=0;
String linenoStr="";
double quantityTemp = 0,rateStduomTemp = 0,taxAmtTemp = 0,discAmtTemp = 0,currtotalNetAmt=0;
boolean cpFlag = false;
try {
......@@ -3686,6 +3686,16 @@ public class DispatchIC extends ValidatorEJB implements DispatchICLocal,Dispatch
{
valueXmlString.append("<rd_permit_no protect = '0'>").append("<![CDATA[" + rdPermitNo + "]]>").append("</rd_permit_no>");
}
//Pavan Rane 11jun19 start [to store the channel partner flag]
cpFlag = isChannelPartnerCust(custCode, siteCode, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 start
} // end ic
else if (currentColumn.trim().equalsIgnoreCase("site_code"))
{
......@@ -3828,13 +3838,34 @@ public class DispatchIC extends ValidatorEJB implements DispatchICLocal,Dispatch
else
{
valueXmlString.append("<rd_permit_no protect = '0'>").append("<![CDATA[" + rdPermitNo + "]]>").append("</rd_permit_no>");
}
//Pavan Rane 11jun19 start [to store the channel partner flag]
cpFlag = isChannelPartnerCust(custCode, siteCode, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
}
else if (currentColumn.trim().equalsIgnoreCase("cust_code"))
{
custCode = genericUtility.getColumnValue("cust_code", dom);
custName = getValue("cust_name", "customer", "cust_code", custCode, conn);
valueXmlString.append("<cust_name protect = '1'>").append("<![CDATA[" + custName + "]]>").append("</cust_name>");
valueXmlString.append("<cust_name protect = '1'>").append("<![CDATA[" + custName + "]]>").append("</cust_name>");
//Pavan Rane 11jun19 start [to store the channel partner flag]
siteCode = genericUtility.getColumnValue("site_code", dom);
cpFlag = isChannelPartnerCust(custCode, siteCode, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
}
else if (currentColumn.trim().equalsIgnoreCase("curr_code"))
{
......@@ -7071,7 +7102,87 @@ public class DispatchIC extends ValidatorEJB implements DispatchICLocal,Dispatch
return totalNetQt;
}
//Added By PriyankaC to get net quantity of despatch for validation on 15Nov2015. [START]
//Pavan Rane 11jun19 start [to validate Channel Partner customer]
private boolean isChannelPartnerCust(String custCode, String siteCode, Connection conn) throws ITMException
{
String sql = "";
String disLink = "";
String chPartner = "";
boolean cpFlag = false;
ResultSet rs = null;
PreparedStatement pstmt = null;
try
{
sql="select channel_partner, dis_link from site_customer "
+ " where cust_code = ? and site_code = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,custCode);
pstmt.setString(2,siteCode);
rs=pstmt.executeQuery();
if(rs.next())
{
chPartner=checkNull(rs.getString("channel_partner"));
disLink=checkNull(rs.getString("dis_link"));
}
rs.close();
rs=null;
pstmt.close();
pstmt=null;
if(chPartner.trim().length()==0)
{
sql="select channel_partner, dis_link from customer "
+ " where cust_code = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,custCode);
rs=pstmt.executeQuery();
if(rs.next())
{
chPartner=checkNull(rs.getString("channel_partner"));
disLink=checkNull(rs.getString("dis_link"));
}
rs.close();
rs=null;
pstmt.close();
pstmt=null;
}
if("Y".equalsIgnoreCase(chPartner))
{
if (("A".equalsIgnoreCase(disLink)|| "S".equalsIgnoreCase(disLink) || "C".equalsIgnoreCase(disLink) ))
{
cpFlag = true;
}
}
} catch (SQLException se)
{
BaseLogger.log("0", null, null, "SQLException :DispatchIC :IsCustChannelP()::" + se.getMessage());
se.printStackTrace();
}
catch (Exception e)
{
BaseLogger.log("0", null, null, "Exception :DispatchIC :IsCustChannelP()::" + e.getMessage());
e.printStackTrace();
} finally
{
try
{
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (rs != null)
{
rs.close();
rs = null;
}
} catch (Exception e)
{
}
}
return cpFlag;
}
//Pavan Rane 11jun19 end
}
\ No newline at end of file
......@@ -10,7 +10,7 @@ import ibase.webitm.ejb.dis.PoReceiptIcRemote;
import ibase.webitm.ejb.fin.FinCommon;
import ibase.webitm.ejb.sys.UtilMethods;
import ibase.webitm.utility.ITMException;
import ibase.utility.BaseLogger;
import java.math.BigDecimal;
import java.rmi.RemoteException;
import java.sql.Connection;
......@@ -4045,6 +4045,7 @@ public class PoReceiptIc extends ValidatorEJB implements PoReceiptIcLocal,PoRec
SimpleDateFormat sdf1=null;
ArrayList acctDetrList = new ArrayList();
UtilMethods utilMethod = new UtilMethods();
boolean cpFlag = false;
try {
System.out.println("**********ITEMCHANGE FOR CASE*********************");
sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
......@@ -4284,6 +4285,16 @@ public class PoReceiptIc extends ValidatorEJB implements PoReceiptIcLocal,PoRec
pstmt = null;
valueXmlString.append("<purc_order>").append("<![CDATA["+purcorder.trim()+"]]>").append("</purc_order>");
}
//Pavan Rane 11jun19 start [to store the channel partner flag]
cpFlag = isChannelPartnerSupp(suppcode, sitecode, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
}
}
else if (currentColumn.trim().equalsIgnoreCase("supp_code"))
......@@ -4463,6 +4474,16 @@ public class PoReceiptIc extends ValidatorEJB implements PoReceiptIcLocal,PoRec
valueXmlString.append("<qc_reqd>").append("<![CDATA["+lsqcreqd+"]]>").append("</qc_reqd>");
}
}
//Pavan Rane 11jun19 start [to store the channel partner flag]
cpFlag = isChannelPartnerSupp(suppcode, sitecode, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
}
}
else if (currentColumn.trim().equalsIgnoreCase("supp_code__ship"))
......@@ -4825,7 +4846,16 @@ public class PoReceiptIc extends ValidatorEJB implements PoReceiptIcLocal,PoRec
qcSiteCode= genericUtility.getColumnValue("site_code", dom);
System.out.println("Supp COde["+mScode+"]");
System.out.println("Site Code["+qcSiteCode+"]");
//Pavan Rane 11jun19 start [to store the channel partner flag]
cpFlag = isChannelPartnerSupp(mScode, qcSiteCode, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
//Added by PriyankaC on 09MAY2019 to get qc_reqd from itemser [START].
itemser = genericUtility.getColumnValue("itemser", dom);
System.out.println("itemser["+itemser+"]");
......@@ -5848,7 +5878,18 @@ public class PoReceiptIc extends ValidatorEJB implements PoReceiptIcLocal,PoRec
valueXmlString.append("<transporter_name>").append("<![CDATA[" + descr + "]]>").append("</transporter_name>");
}
if(lspurcorder == null)
{
{
//Pavan R 08jun19 start[to update channel P flag]
siteCode = genericUtility.getColumnValue("site_code", dom);
cpFlag = isChannelPartnerSupp(scode, siteCode, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan R 08jun19 end
valueXmlString.append("<supp_code>").append("<![CDATA[" + scode + "]]>").append("</supp_code>");
valueXmlString.append("<supp_code__ship>").append("<![CDATA[" + scode + "]]>").append("</supp_code__ship>");
sql=" select supp_name from supplier where supp_code =?";
......@@ -10950,4 +10991,88 @@ public class PoReceiptIc extends ValidatorEJB implements PoReceiptIcLocal,PoRec
tempNode = null;
}
//Add by Ajay Jadhav on 12/04/2018:END
}
//Pavan Rane 11jun19 start [to validate Channel Partner Supplier]
private boolean isChannelPartnerSupp(String suppCode, String siteCode, Connection conn) throws ITMException
{
String sql = "";
String disLink = "";
String chPartner = "";
boolean cpFlag = false;
ResultSet rs = null;
PreparedStatement pstmt = null;
try
{
sql="select channel_partner, dis_link from site_supplier "
+ " where supp_code = ? and site_code = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,suppCode);
pstmt.setString(2,siteCode);
rs=pstmt.executeQuery();
if(rs.next())
{
chPartner=checkNull(rs.getString("channel_partner"));
disLink=checkNull(rs.getString("dis_link"));
}
rs.close();
rs=null;
pstmt.close();
pstmt=null;
if(chPartner.trim().length()==0)
{
sql="select channel_partner, dis_link from supplier "
+ " where supp_code = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,suppCode);
rs=pstmt.executeQuery();
if(rs.next())
{
chPartner=checkNull(rs.getString("channel_partner"));
disLink=checkNull(rs.getString("dis_link"));
}
rs.close();
rs=null;
pstmt.close();
pstmt=null;
}
if("Y".equalsIgnoreCase(chPartner))
{
if (("A".equalsIgnoreCase(disLink)|| "S".equalsIgnoreCase(disLink) || "C".equalsIgnoreCase(disLink) ))
{
cpFlag = true;
}
}
} catch (SQLException se)
{
BaseLogger.log("0", null, null, "SQLException :PoReceiptIc :isChannelPartnerSupp()::" + se.getMessage());
se.printStackTrace();
}
catch (Exception e)
{
BaseLogger.log("0", null, null, "Exception :PoReceiptIc :isChannelPartnerSupp()::" + e.getMessage());
e.printStackTrace();
} finally
{
try
{
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (rs != null)
{
rs.close();
rs = null;
}
} catch (Exception e)
{
}
}
return cpFlag;
}
//Pavan Rane 11jun19 end
}
\ No newline at end of file
package ibase.webitm.ejb.dis;
import ibase.utility.E12GenericUtility;
//import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import org.w3c.dom.Document;
@javax.ejb.Stateless
public class PoReceiptVerifyPasswordIC extends ValidatorEJB implements PoReceiptVerifyPasswordICLocal, PoReceiptVerifyPasswordICRemote
{
E12GenericUtility genericUtility = new E12GenericUtility();
//DistCommon discommon = new DistCommon();
//ITMDBAccessEJB itmDBAccess = new ITMDBAccessEJB();
@Override
public String wfValData() throws RemoteException, ITMException
{
return "";
}
/**
* The public method is used for converting the current form data into a document(DOM)
* The dom is then given as argument to the overloaded function wfValData to perform validation
* Returns validation string if exists else returns null in XML format
* @param xmlString contains the current form data in XML format
* @param xmlString1 contains all the header information in the XML format
* @param xmlString2 contains the data of all the forms in XML format
* @param objContext represents the form number
* @param editFlag represents the mode of transaction(A-Add or E-Edit)
* @param xtraParams contains additional information such as loginEmpCode,loginCode,chgTerm etc
*/
@Override
public String itemChanged() throws RemoteException, ITMException
{
return "";
}
@Override
public String itemChanged(String xmlString, String xmlString1, String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException, ITMException
{
Document currFormDataDom = null;
Document hdrDataDom = null;
Document allFormDataDom = null;
String errString = null;
E12GenericUtility genericUtility = new E12GenericUtility();
System.out.println("-----------Calling PoReceiptVerifyPasswordIC----itemChanged(String)----------");
System.out.println("xmlString ["+xmlString+"]");
System.out.println("xmlString1 ["+xmlString1+"]");
System.out.println("xmlString2 ["+xmlString2+"]");
try
{
if (xmlString != null && xmlString.trim().length()!=0)
{
currFormDataDom = genericUtility.parseString(xmlString);
}
if (xmlString1 != null && xmlString1.trim().length()!=0)
{
hdrDataDom = genericUtility.parseString(xmlString1);
}
if (xmlString2 != null && xmlString2.trim().length()!=0)
{
allFormDataDom = genericUtility.parseString(xmlString2);
}
errString = itemChanged( currFormDataDom, hdrDataDom, allFormDataDom, objContext, currentColumn, editFlag, xtraParams );
}
catch (Exception e)
{
System.out.println("Exception :PoReceiptVerifyPasswordIC :itemChanged(String):"+ e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
@Override
public String itemChanged( Document currFormDataDom, Document hdrDataDom, Document allFormDataDom, String objContext, String currentColumn, String editFlag, String xtraParams ) throws RemoteException,ITMException
{
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
int currentFormNo = 0;
StringBuffer valueXmlString;
String sql = "", tranId = "",confirm = "", passwd = "";
System.out.println("-----------Calling PoReceiptVerifyPasswordIC----itemChanged(Document)----------");
System.out.println("xtraParams=["+xtraParams+"]");
valueXmlString = new StringBuffer( "<?xml version=\"1.0\"?><Root><Header><editFlag>" );
valueXmlString.append( editFlag ).append( "</editFlag></Header>" );
try
{
conn = getConnection();
if( objContext != null && objContext.trim().length() > 0 )
{
currentFormNo = Integer.parseInt( objContext );
}
switch ( currentFormNo )
{
case 1:
{
System.out.println("inside itemChanged...Case - 1..currentColumn: ["+currentColumn+"] currentFormNo: ["+currentFormNo+"]");
valueXmlString.append( "<Detail1>\r\n" );
if( currentColumn.trim().equalsIgnoreCase( "itm_default" ) )
{
System.out.println("<<--------- Inside Case1 itemChanged for item default --------------->> ");
tranId = checkNull(genericUtility.getColumnValue("tran_id",currFormDataDom));
System.out.println("Pavan Rane TranID["+tranId+"]");
sql = "select confirmed, conf_passwd from porcp where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
confirm = checkNull(rs.getString(1));
passwd = checkNull(rs.getString(2));
}
rs.close();rs = null;
pstmt.close();pstmt = null;
//if isnull(ls_passwd) or mconfirm = 'Y' then
if(passwd == null || passwd.length() == 0 || "Y".equals(confirm))
{
valueXmlString.append( "<conf_passwd protect = '1'><![CDATA[]]></conf_passwd>\r\n" );
}
else {
//gbf_itemchg_modifier_ds(dw_currobj,"conf_passwd","protect","0")
valueXmlString.append( "<conf_passwd protect = '0'><![CDATA[]]></conf_passwd>\r\n" );
}
}
if( currentColumn.trim().equalsIgnoreCase( "tran_id" ) )
{
tranId = checkNull(genericUtility.getColumnValue("tran_id",currFormDataDom));
sql = "select confirmed, conf_passwd from porcp where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
confirm = rs.getString(1);
passwd = rs.getString(2);
}
rs.close();rs = null;
pstmt.close();pstmt = null;
//if isnull(ls_passwd) or mconfirm = 'Y' then
if(passwd == null || passwd.length() == 0 || "Y".equals(confirm))
{
valueXmlString.append( "<conf_passwd protect = '1'><![CDATA[]]></conf_passwd>\r\n" );
}
else
{
valueXmlString.append( "<conf_passwd protect = '0'><![CDATA[]]></conf_passwd>\r\n" );
}
}
valueXmlString.append( "</Detail1>\r\n" );
} //Case 1. End
break;
}//End of switch block
valueXmlString.append( "</Root>\r\n" );
}
catch (Exception e)
{
System.out.println("Exception :PoReceiptVerifyPasswordIC :itemChanged(Document):"+ e.getMessage() + ":");
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.close();
conn = null;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
}
System.out.println( "valueXmlString.toString()>>>>>>>::"+valueXmlString.toString());
return valueXmlString.toString();
}
private String checkNull(String input)
{
if ( input == null )
{
input = "";
}
return input.trim();
}
}
package ibase.webitm.ejb.dis;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import java.rmi.RemoteException;
import org.w3c.dom.Document;
@javax.ejb.Local
public interface PoReceiptVerifyPasswordICLocal extends ValidatorLocal
{
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 currFormDataDom, Document hdrDataDom, Document allFormDataDom, String objContext, String currentColumn,String editFlag, String xtraParams ) throws RemoteException, ITMException;
}
package ibase.webitm.ejb.dis;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import java.rmi.RemoteException;
import org.w3c.dom.Document;
@javax.ejb.Remote
public interface PoReceiptVerifyPasswordICRemote extends ValidatorRemote
{
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 currFormDataDom, Document hdrDataDom, Document allFormDataDom, String objContext, String currentColumn,String editFlag, String xtraParams ) throws RemoteException, ITMException;
}
/* Developed By Pavan Rane.
* Date : 12-JUN-2019
* Component Name : SalesReturnVerifyPasswordPrc
*/
package ibase.webitm.ejb.dis;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ProcessEJB;
import ibase.webitm.ejb.dis.adv.PoRcpConf;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import javax.ejb.Stateless;
import org.w3c.dom.Document;
/**
* Session Bean implementation class EmpMaritalStatusConfPrc
*/
@Stateless
public class PoReceiptVerifyPasswordPrc extends ProcessEJB implements PoReceiptVerifyPasswordPrcRemote, PoReceiptVerifyPasswordPrcLocal
{
E12GenericUtility genericUtility = new E12GenericUtility();
public String process() throws RemoteException, ITMException
{
return "";
}
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException, ITMException
{
String retString = "";
Document detailDom = null;
Document headerDom = null;
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);
}
retString = process(headerDom, detailDom, windowName, xtraParams);
} catch (Exception e)
{
System.out.println("Exception :SalesReturnVerifyPasswordPrc :process(String):"+ e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
return retString;
}
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException, ITMException {
System.out.println("-----------Calling PoReceiptVerifyPasswordPrc----process(Document)----------");
String returnString = "", tranId = "", sql = "", lsPasswd = "", lsConfirm = "", lsEntPasswd = "";
String lsPwdVerified = "N";
boolean isError = false;
Connection conn = null;
ITMDBAccessEJB itmDBAccess = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try
{
conn = getConnection();
conn.setAutoCommit(false);
itmDBAccess = new ITMDBAccessEJB();
tranId = genericUtility.getColumnValue("tran_id", detailDom);
System.out.println("PO Receipt No: # "+tranId+"]");
if (tranId == null || tranId.trim().length() <= 0)
{
returnString = itmDBAccess.getErrorString("", "VTTRNNULL", "", "", conn);
return returnString;
} else
{
sql = "select conf_passwd, confirmed from porcp where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if (rs.next()) {
lsPasswd = checkNull(rs.getString("conf_passwd"));
lsConfirm = checkNull(rs.getString("confirmed"));
}
pstmt.close();
pstmt = null;
rs.close();
rs = null;
System.out.println("@V@ PAVAN lsPasswd :- [" + lsPasswd + "]");
System.out.println("@V@ PAVAN lsConfirm :- [" + lsConfirm + "]");
if ("Y".equalsIgnoreCase(lsConfirm))
{
returnString = itmDBAccess.getErrorString("", "VTMCONF1", "", "", conn);
return returnString;
} else
{
if (lsPasswd != null && lsPasswd.trim().length() > 0)
{
lsEntPasswd = checkNull(genericUtility.getColumnValue("conf_passwd", detailDom));
System.out.println("@V@ PAVAN lsEntPasswd :- [" + lsEntPasswd + "]");
if (lsEntPasswd == null || lsEntPasswd.trim().length() <= 0 || !(lsEntPasswd.equals(lsPasswd)))
{
returnString = itmDBAccess.getErrorString("", "VPINVDPSWD", "", "", conn);
return returnString;
} else
{
if(lsEntPasswd.equals(lsPasswd))
{
lsPwdVerified = "Y";
}
}
} /*else {
lsPwdVerified = "Y";
}*/
if ("Y".equalsIgnoreCase(lsPwdVerified))
{
// conn.commit();
PoRcpConf poRcpConf = new PoRcpConf();
returnString = poRcpConf.confirm(tranId, xtraParams, "", conn, false);
sql = "select confirmed from porcp where tran_id = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
lsConfirm = checkNull(rs.getString("confirmed"));
}
rs.close(); rs = null;
pstmt.close();pstmt = null;
if(!"Y".equalsIgnoreCase(lsConfirm))
{
conn.rollback();
if(returnString == null || returnString.trim().length() == 0)
{
returnString = itmDBAccess.getErrorString("", "DS000", "","",conn);
isError = true;
}
}
else
{
conn.commit();
returnString = itmDBAccess.getErrorString("", "VTMCONF2", "","",conn);
}
}
} // }
} // TRAN_ID NOT NULL
if (returnString.length() > 0 && returnString.indexOf("VTCONF") > -1) {
returnString = itmDBAccess.getErrorString("", "PRCSUCES", "", "", conn);
} else {
isError = true;
System.out.println("PoReceiptVerifyPasswordPrc isError ::[" + isError + "]");
// returnString = itmDBAccess.getErrorString("", "PRCFAIL", "", "", connection);
}
} catch (Exception e) {
isError = true;
System.out.println("Exception :PoReceiptVerifyPasswordPrc :process(Documents):"+ e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
} finally {
System.out.println("Finally Closing Connection....");
try {
if (isError) {
conn.rollback();
System.out.println("PoReceiptVerifyPasswordPrc connection rollback");
} else {
conn.commit();
System.out.println("PoReceiptVerifyPasswordPrc connection committed");
}
if (conn != null) {
conn.close();
conn = null;
}
} catch (Exception e) {
returnString = e.getMessage();
e.printStackTrace();
}
}
System.out.println("errString...:: " + returnString);
return returnString;
}
private String checkNull(String input) {
if (input == null || ("null").equalsIgnoreCase(input.trim())) {
input = "";
} else {
input = input.trim();
}
return input;
}
}
package ibase.webitm.ejb.dis;
import ibase.webitm.ejb.ProcessLocal;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import javax.ejb.Local;
import org.w3c.dom.Document;
@Local
public interface PoReceiptVerifyPasswordPrcLocal extends ProcessLocal
{
public String process() 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;
}
package ibase.webitm.ejb.dis;
import ibase.webitm.ejb.ProcessRemote;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import javax.ejb.Remote;
import org.w3c.dom.Document;
@Remote
public interface PoReceiptVerifyPasswordPrcRemote extends ProcessRemote
{
public String process() 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;
}
......@@ -4,6 +4,7 @@ import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
......@@ -22,6 +23,7 @@ import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import ibase.system.config.ConnDriver;
import ibase.utility.BaseLogger;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ValidatorEJB;
......@@ -2568,7 +2570,7 @@ PoReturnICRemote {
// itemchange on edit mode
long ll_cnt = 0, ll_tax = 0;
String sysDate = "";
boolean cpFlag = false;
double mPcnt = 0;
try {
......@@ -2966,8 +2968,16 @@ PoReturnICRemote {
.append("<![CDATA[]]>").append("</rec_date>");
//this.gbf_exchrate_protect(ls_curr, ls_site, "exch_rate");
//Pavan Rane 11jun19 start [to store the channel partner flag]
cpFlag = isChannelPartnerSupp(ls_supp, ls_site, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
if (ls_curr != null
&& ls_curr.trim().length() > 0)
{
......@@ -3080,6 +3090,17 @@ PoReturnICRemote {
rs = null;
pstmt.close();
pstmt = null;
//Pavan Rane 11jun19 start [to store the channel partner flag]
mcode1 = checkNull(genericUtility.getColumnValue("site_code", dom));
cpFlag = isChannelPartnerSupp(mcode, mcode1, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
valueXmlString.append("<transporter_name>")
.append("<![CDATA[" + ls_tranname + "]]>")
......@@ -3202,7 +3223,17 @@ PoReturnICRemote {
valueXmlString.append("<site_descr>")
.append("<![CDATA[" + mSdesc + "]]>")
.append("</site_descr>");
//Pavan Rane 11jun19 start [to store the channel partner flag]
mScode = checkNull(genericUtility.getColumnValue("supp_code", dom));
cpFlag = isChannelPartnerSupp(mScode, mcode, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
} else if (currentColumn.trim().equalsIgnoreCase("purc_order")) {
mcode = checkNull(genericUtility.getColumnValue(
"purc_order", dom));
......@@ -3370,7 +3401,16 @@ PoReturnICRemote {
///this.gbf_exchrate_protect(mCurr, ls_site_dlv, "ls_site_dlv");//gbf_exchrate_protect(mCurr,ls_site_dlv,'ls_site_dlv')
// gbf_exchrate_protect(mCurr,ls_site_dlv,"exch_rate");//pravin
//Pavan Rane 11jun19 start [to store the channel partner flag]
cpFlag = isChannelPartnerSupp(mScode, ls_site_dlv, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
if (mCurr != null && mCurr.trim().length() > 0) {
sql = "select a.curr_code "
......@@ -7628,4 +7668,87 @@ PoReturnICRemote {
return nodes;
}
//Added by sarita to get Detail2 total quantity on 22 OCT 2018 [END]
}
//Pavan Rane 11jun19 start [to validate Channel Partner Supplier]
private boolean isChannelPartnerSupp(String suppCode, String siteCode, Connection conn) throws ITMException
{
String sql = "";
String disLink = "";
String chPartner = "";
boolean cpFlag = false;
ResultSet rs = null;
PreparedStatement pstmt = null;
try
{
sql="select channel_partner, dis_link from site_supplier "
+ " where supp_code = ? and site_code = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,suppCode);
pstmt.setString(2,siteCode);
rs=pstmt.executeQuery();
if(rs.next())
{
chPartner=checkNull(rs.getString("channel_partner"));
disLink=checkNull(rs.getString("dis_link"));
}
rs.close();
rs=null;
pstmt.close();
pstmt=null;
if(chPartner.trim().length()==0)
{
sql="select channel_partner, dis_link from supplier "
+ " where supp_code = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,suppCode);
rs=pstmt.executeQuery();
if(rs.next())
{
chPartner=checkNull(rs.getString("channel_partner"));
disLink=checkNull(rs.getString("dis_link"));
}
rs.close();
rs=null;
pstmt.close();
pstmt=null;
}
if("Y".equalsIgnoreCase(chPartner))
{
if (("A".equalsIgnoreCase(disLink)|| "S".equalsIgnoreCase(disLink) || "C".equalsIgnoreCase(disLink) ))
{
cpFlag = true;
}
}
} catch (SQLException se)
{
BaseLogger.log("0", null, null, "SQLException :PoReturnIc :IsChannelPartnerSupp()::" + se.getMessage());
se.printStackTrace();
}
catch (Exception e)
{
BaseLogger.log("0", null, null, "Exception :PoReturnIc :IsChannelPartnerSupp()()::" + e.getMessage());
e.printStackTrace();
} finally
{
try
{
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (rs != null)
{
rs.close();
rs = null;
}
} catch (Exception e)
{
}
}
return cpFlag;
}
}
\ No newline at end of file
......@@ -12,7 +12,7 @@ import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.HashMap;
import javax.naming.InitialContext;
import ibase.utility.BaseLogger;
import org.w3c.dom.Document;
import java.sql.Timestamp;
......@@ -38,7 +38,7 @@ import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.TransIDGenerator;
import ibase.system.config.AppConnectParm;
import ibase.system.config.ConnDriver;
import java.util.Random;
import ibase.webitm.ejb.MasterStatefulLocal;
public class PostOrdDespatchGen
......@@ -143,6 +143,7 @@ public class PostOrdDespatchGen
HashMap invAllocTraceMap = null;
InvAllocTraceBean invBean = null;
String sqlSord = "";
boolean cpFlag = false;
try {
startTime = System.currentTimeMillis();
//System.out.println("process starts---------");
......@@ -1648,6 +1649,11 @@ public class PostOrdDespatchGen
tranId = tg.generateTranSeqID(tranSer1, keyCol, keyString, conn);
//System.out.println("@@@@ generated tranId :["+tranId+"]");
gpNo=generateGpNo("gpno",siteCde,tempMap.get("sord_no").toString(),conn);
//Pavan Rane 11jun19 start [to generate password channel partner auto receitp]
Random pwdGenerator = new Random();
String confPasswd = "" + pwdGenerator.nextInt(12345678);
System.out.println("CPDespatch PWD #"+confPasswd);
//Pavan Rane 11jun19 end
//Pavan Rane 11mar19 start [despatch generation instead of dire insert xml to be generated and processrequest to be called]
/*confirmed="N";
sql="Insert into despatch(desp_id,desp_date,sord_no,sord_date,cust_code,cust_code__dlv," +
......@@ -1791,7 +1797,19 @@ public class PostOrdDespatchGen
xmlBuff.append("<remarks><![CDATA[" + tempMap.get("remarks") + "]]></remarks>");
}else {
xmlBuff.append("<remarks><![CDATA[" + "" + "]]></remarks>");
}
}
//Pavan Rane 11jun19 start [to store the channel partner flag]
cpFlag = isChannelPartnerCust(custCode, siteCode, conn);
if(cpFlag)
{
xmlBuff.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
xmlBuff.append("<conf_passwd><![CDATA[" + confPasswd + "]]></conf_passwd>");
}else
{
xmlBuff.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
xmlBuff.append("<conf_passwd><![CDATA[ ]]></conf_passwd>");
}
////Pavan Rane 11jun19 start
xmlBuff.append("</Detail1>");
//Pavan Rane 11mar19 end
sumNetAmt = 0.0D;
......@@ -2286,7 +2304,7 @@ public class PostOrdDespatchGen
//pavan R 20/jul/18 changed the lookup to creating instance of the class using new keyword.
DespatchConfirm despatchConfirm = new DespatchConfirm();
String forcedFlag="N";
connCP=chaneParnerExist(tranId,xtraParams,conn);
connCP=chaneParnerExist(tranId,xtraParams,conn);
if(connCP!=null )
{ //Modified by Azhar K. on [07-05-2019][Start]
//errString=despatchConfirm.confirm(tranId, xtraParams, forcedFlag,conn,connCP);
......@@ -3088,4 +3106,87 @@ public class PostOrdDespatchGen
return retString;
}
//Pavan R 11mar19 processreq end
//Pavan Rane 11jun19 start [to validate Channel Partner customer]
private boolean isChannelPartnerCust(String custCode, String siteCode, Connection conn) throws ITMException
{
String sql = "";
String disLink = "";
String chPartner = "";
boolean cpFlag = false;
ResultSet rs = null;
PreparedStatement pstmt = null;
try
{
sql="select channel_partner, dis_link from site_customer "
+ " where cust_code = ? and site_code = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,custCode);
pstmt.setString(2,siteCode);
rs=pstmt.executeQuery();
if(rs.next())
{
chPartner=checkNull(rs.getString("channel_partner"));
disLink=checkNull(rs.getString("dis_link"));
}
rs.close();
rs=null;
pstmt.close();
pstmt=null;
if(chPartner.trim().length()==0)
{
sql="select channel_partner, dis_link from customer "
+ " where cust_code = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,custCode);
rs=pstmt.executeQuery();
if(rs.next())
{
chPartner=checkNull(rs.getString("channel_partner"));
disLink=checkNull(rs.getString("dis_link"));
}
rs.close();
rs=null;
pstmt.close();
pstmt=null;
}
if("Y".equalsIgnoreCase(chPartner))
{
if (("A".equalsIgnoreCase(disLink)|| "S".equalsIgnoreCase(disLink) || "C".equalsIgnoreCase(disLink) ))
{
cpFlag = true;
}
}
} catch (SQLException se)
{
BaseLogger.log("0", null, null, "SQLException :PostOrdDespatchGen :IsCustChannelP()::" + se.getMessage());
se.printStackTrace();
}
catch (Exception e)
{
BaseLogger.log("0", null, null, "Exception :PostOrdDespatchGen :IsCustChannelP()::" + e.getMessage());
e.printStackTrace();
} finally
{
try
{
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (rs != null)
{
rs.close();
rs = null;
}
} catch (Exception e)
{
}
}
return cpFlag;
}
//Pavan Rane 11jun19 end
}
\ No newline at end of file
......@@ -230,7 +230,7 @@ public class PostOrderActivity {
String xmlString="",chgUser="",chgTerm="",loginEmpCode="";
Timestamp sysDate=null;
String userId = "";//Added By Pavan R 27/DEC/17
String custPordPO = "", itemCodeDesp = "";
String custPordPO = "", itemCodeDesp = "", isChannelPartner = "", confPasswd = "";
try
{
//Modified by Anjali R. on [23/11/2018][Start]
......@@ -281,7 +281,7 @@ public class PostOrderActivity {
sql="select d.desp_date,d.site_code,d.sord_no,d.curr_code,d.exch_rate,"
+ "d.lr_no,d.lr_date,d.lorry_no,d.tran_code,d.trans_mode,"
+ "d.gp_no,d.gp_date,"
+ "s.remarks2,s.remarks3,d.stan_code__init,d.remarks "
+ "s.remarks2,s.remarks3,d.stan_code__init,d.remarks, d.conf_passwd "
+ " from despatch d, sorder s where d.sord_no=s.sale_order and d.desp_id=?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,despId);
......@@ -304,6 +304,8 @@ public class PostOrderActivity {
gpDate=rs.getTimestamp("gp_date");
stanCodeInit=rs.getString("stan_code__init");
remarks=rs.getString("remarks");
confPasswd = rs.getString("conf_passwd");//Pavan Rane 11jun19 start [to store the channel partner flag]
System.out.println("CPRCP PWD #"+confPasswd);
// 28/Nov-16 manoharan cust_pord included and separate select commented
sql="select item_ser, cust_code,cust_pord from sorder where sale_order = ? ";
pstmt1=conn.prepareStatement(sql);
......@@ -370,6 +372,7 @@ public class PostOrderActivity {
{
suppCodeCh=checkNull(rs.getString("supp_code")).trim();
suppCodemnfr=suppCodeCh;
isChannelPartner = "Y";
}
rs.close();
rs=null;
......@@ -387,6 +390,7 @@ public class PostOrderActivity {
{
suppCodeCh=checkNull(rs.getString("supp_code")).trim();
suppCodemnfr=suppCodeCh;
isChannelPartner = "Y";
}
rs.close();
rs=null;
......@@ -762,6 +766,16 @@ public class PostOrderActivity {
//Changes done by mayur on 26-02-18------END
//xmlBuff.append("<excise_ref_date><![CDATA["+sdf.format(gpDate) +"]]></excise_ref_date>");
xmlBuff.append("<freight_status><![CDATA[T]]></freight_status>");
//Pavan Rane 11jun19 start [to store the channel partner flag and generated password]
if("Y".equals(isChannelPartner))
{
xmlBuff.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
xmlBuff.append("<conf_passwd><![CDATA[" + confPasswd + "]]></conf_passwd>");
}else {
xmlBuff.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
xmlBuff.append("<conf_passwd><![CDATA[ ]]></conf_passwd>");
}
//Pavan Rane 11jun19 end
xmlBuff.append("</Detail1>");
String itemCode="",sordNoDet="",soLineNoDet="",taxClass="",taxChap="",taxEnv="";
......@@ -5446,4 +5460,4 @@ public class PostOrderActivity {
return integralPart;
}
// Added By PriyankaC update scheme_balance as per the nature [END].
}
}
\ No newline at end of file
......@@ -6,6 +6,7 @@
********************************************************/
package ibase.webitm.ejb.dis;
import ibase.utility.BaseLogger;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.dis.DistCommon;
import ibase.webitm.ejb.fin.FinCommon;
......@@ -409,6 +410,7 @@ public class SalesReturn extends ValidatorEJB implements SalesReturnLocal, Sales
Timestamp invRefDateStr=null;// Added by Nandkumar Gadkari on 19MAR2018
ArrayList<String> dokkeyList=null; // Added by Nandkumar Gadkari on 14/09/18
String expDateStrg="",mfgDateStrg="";// added by nandkumar gadkari on 28/01/19
boolean cpFlag = false;
try
{
// Changed by Sneha on 22-07-2016 for exchange rate [Start]
......@@ -797,7 +799,17 @@ public class SalesReturn extends ValidatorEJB implements SalesReturnLocal, Sales
pstmt = null;
rs = null;
}
//Pavan Rane 11jun19 start [to store the channel partner flag]
cpFlag = isChannelPartnerCust(custCode, siteCode, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
reStr = itemChanged(dom, dom1, dom2, objContext, "curr_code", editFlag, xtraParams);
//System.out.println("modified string [" + reStr + "]");
//<?xml version="1.0"?><Root><header><editFlag>E</editFlag></header><Detail2><item_ser__prom><![CDATA[CO]]></item_ser__prom><descr><![CDATA[FERTIGYN 5000FERTIGYN]]></descr><item_ser><![CDATA[ZT]]></item_ser><unit><![CDATA[A01]]></unit><loc_type><![CDATA[C1]]></loc_type><curr_stk><![CDATA[200000.0]]></curr_stk><st_scheme><![CDATA[]]></st_scheme><st_scheme><![CDATA[Integral Quantity :4.0]]></st_scheme><cust_item__ref><![CDATA[0132 ]]></cust_item__ref><cust_item_ref_descr><![CDATA[SAWAN TEST ]]></cust_item_ref_descr></Detail2></Root>
......@@ -1052,7 +1064,16 @@ public class SalesReturn extends ValidatorEJB implements SalesReturnLocal, Sales
valueXmlString.append("<cust_name__dlv>").append("<![CDATA[" + getAbsString( custName ) + "]]>").append("</cust_name__dlv>");
setNodeValue( dom, "cust_name__dlv", getAbsString( custName ) );
//Pavan Rane 11jun19 start [to store the channel partner flag]
cpFlag = isChannelPartnerCust(custCode, siteCode, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
priceListClg = "";
sql = " select price_list__clg from site_customer where cust_code = ? and site_code = ?";
pstmt= conn.prepareStatement( sql );
......@@ -1298,6 +1319,17 @@ public class SalesReturn extends ValidatorEJB implements SalesReturnLocal, Sales
pstmt = null;
rs = null;
valueXmlString.append("<site_descr>").append("<![CDATA[" + getAbsString( descr ) + "]]>").append("</site_descr>");
//Pavan Rane 11jun19 start [to store the channel partner flag]
custCode = genericUtility.getColumnValue("cust_code",dom);
cpFlag = isChannelPartnerCust(custCode, siteCode, conn);
if(cpFlag)
{
valueXmlString.append("<channel_partner><![CDATA[" + "Y" + "]]></channel_partner>");
}else
{
valueXmlString.append("<channel_partner><![CDATA[" + "N" + "]]></channel_partner>");
}
//Pavan Rane 11jun19 end
reStr = itemChanged(dom, dom1, dom2, objContext, "ret_opt", editFlag, xtraParams);
pos = reStr.indexOf("<Detail1>");
......@@ -11581,6 +11613,89 @@ public class SalesReturn extends ValidatorEJB implements SalesReturnLocal, Sales
return valueXmlString;
}
// added by Nandkumar Gadkari on 16/11/18 ------------------end----------------------------------
//Pavan Rane 11jun19 start [to validate Channel Partner customer]
private boolean isChannelPartnerCust(String custCode, String siteCode, Connection conn) throws ITMException
{
String sql = "";
String disLink = "";
String chPartner = "";
boolean cpFlag = false;
ResultSet rs = null;
PreparedStatement pstmt = null;
try
{
sql="select channel_partner, dis_link from site_customer "
+ " where cust_code = ? and site_code = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,custCode);
pstmt.setString(2,siteCode);
rs=pstmt.executeQuery();
if(rs.next())
{
chPartner=checkNull(rs.getString("channel_partner"));
disLink=checkNull(rs.getString("dis_link"));
}
rs.close();
rs=null;
pstmt.close();
pstmt=null;
if(chPartner.trim().length()==0)
{
sql="select channel_partner, dis_link from customer "
+ " where cust_code = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,custCode);
rs=pstmt.executeQuery();
if(rs.next())
{
chPartner=checkNull(rs.getString("channel_partner"));
disLink=checkNull(rs.getString("dis_link"));
}
rs.close();
rs=null;
pstmt.close();
pstmt=null;
}
if("Y".equalsIgnoreCase(chPartner))
{
if (("A".equalsIgnoreCase(disLink)|| "S".equalsIgnoreCase(disLink) || "C".equalsIgnoreCase(disLink) ))
{
cpFlag = true;
}
}
} catch (SQLException se)
{
BaseLogger.log("0", null, null, "SQLException :SalesReturn :IsChannelPartnerCust()::" + se.getMessage());
se.printStackTrace();
}
catch (Exception e)
{
BaseLogger.log("0", null, null, "Exception :SalesReturn :IsChannelPartnerCust()::" + e.getMessage());
e.printStackTrace();
} finally
{
try
{
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
if (rs != null)
{
rs.close();
rs = null;
}
} catch (Exception e)
{
}
}
return cpFlag;
}
//Pavan Rane 11jun19 end
}// END OF MAIN CLASS
\ No newline at end of file
package ibase.webitm.ejb.dis;
import ibase.utility.E12GenericUtility;
//import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import org.w3c.dom.Document;
@javax.ejb.Stateless
public class SalesReturnVerifyPasswordIC extends ValidatorEJB implements SalesReturnVerifyPasswordICLocal, SalesReturnVerifyPasswordICRemote
{
E12GenericUtility genericUtility = new E12GenericUtility();
//DistCommon discommon = new DistCommon();
//ITMDBAccessEJB itmDBAccess = new ITMDBAccessEJB();
@Override
public String wfValData() throws RemoteException, ITMException
{
return "";
}
/**
* The public method is used for converting the current form data into a document(DOM)
* The dom is then given as argument to the overloaded function wfValData to perform validation
* Returns validation string if exists else returns null in XML format
* @param xmlString contains the current form data in XML format
* @param xmlString1 contains all the header information in the XML format
* @param xmlString2 contains the data of all the forms in XML format
* @param objContext represents the form number
* @param editFlag represents the mode of transaction(A-Add or E-Edit)
* @param xtraParams contains additional information such as loginEmpCode,loginCode,chgTerm etc
*/
@Override
public String itemChanged() throws RemoteException, ITMException
{
return "";
}
@Override
public String itemChanged(String xmlString, String xmlString1, String xmlString2, String objContext, String currentColumn, String editFlag, String xtraParams) throws RemoteException, ITMException
{
Document currFormDataDom = null;
Document hdrDataDom = null;
Document allFormDataDom = null;
String errString = null;
E12GenericUtility genericUtility = new E12GenericUtility();
System.out.println("-----------Calling SalesReturnVerifyPasswordIC----itemChanged(String)----------");
try
{
System.out.println("xmlString ["+xmlString+"]");
System.out.println("xmlString1 ["+xmlString1+"]");
System.out.println("xmlString2 ["+xmlString2+"]");
if (xmlString != null && xmlString.trim().length()!=0)
{
currFormDataDom = genericUtility.parseString(xmlString);
}
if (xmlString1 != null && xmlString1.trim().length()!=0)
{
hdrDataDom = genericUtility.parseString(xmlString1);
}
if (xmlString2 != null && xmlString2.trim().length()!=0)
{
allFormDataDom = genericUtility.parseString(xmlString2);
}
errString = itemChanged( currFormDataDom, hdrDataDom, allFormDataDom, objContext, currentColumn, editFlag, xtraParams );
}
catch (Exception e)
{
System.out.println("Exception :SalesReturnVerifyPasswordIC :itemChanged(String):"+ e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
return errString;
}
@Override
public String itemChanged( Document currFormDataDom, Document hdrDataDom, Document allFormDataDom, String objContext, String currentColumn, String editFlag, String xtraParams ) throws RemoteException,ITMException
{
Connection conn = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
int currentFormNo = 0;
StringBuffer valueXmlString;
String sql = "", tranId = "",confirm = "", passwd = "";
System.out.println("-----------Calling SalesReturnVerifyPasswordIC----itemChanged(Document)----------");
System.out.println("xtraParams=["+xtraParams+"]");
valueXmlString = new StringBuffer( "<?xml version=\"1.0\"?><Root><Header><editFlag>" );
valueXmlString.append( editFlag ).append( "</editFlag></Header>" );
try
{
conn = getConnection();
if( objContext != null && objContext.trim().length() > 0 )
{
currentFormNo = Integer.parseInt( objContext );
}
switch ( currentFormNo )
{
case 1:
{
System.out.println("inside itemChanged...Case - 1..currentColumn: ["+currentColumn+"] currentFormNo: ["+currentFormNo+"]");
valueXmlString.append( "<Detail1>\r\n" );
if( currentColumn.trim().equalsIgnoreCase( "itm_default" ) )
{
tranId = checkNull(genericUtility.getColumnValue("tran_id",currFormDataDom));
System.out.println("Pavan Rane TranID["+tranId+"]");
sql = "select confirmed, conf_passwd from sreturn where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
confirm = checkNull(rs.getString(1));
passwd = checkNull(rs.getString(2));
}
rs.close();rs = null;
pstmt.close();pstmt = null;
//if isnull(ls_passwd) or mconfirm = 'Y' then
if(passwd == null || passwd.length() == 0 || "Y".equals(confirm))
{
valueXmlString.append( "<conf_passwd protect = '1'><![CDATA[]]></conf_passwd>\r\n" );
}
else {
//gbf_itemchg_modifier_ds(dw_currobj,"conf_passwd","protect","0")
valueXmlString.append( "<conf_passwd protect = '0'><![CDATA[]]></conf_passwd>\r\n" );
}
}
if( currentColumn.trim().equalsIgnoreCase( "tran_id" ) )
{
tranId = checkNull(genericUtility.getColumnValue("tran_id",currFormDataDom));
sql = "select confirmed, conf_passwd from sreturn where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
confirm = rs.getString(1);
passwd = rs.getString(2);
}
rs.close();rs = null;
pstmt.close();pstmt = null;
//if isnull(ls_passwd) or mconfirm = 'Y' then
if(passwd == null || passwd.length() == 0 || "Y".equals(confirm))
{
valueXmlString.append( "<conf_passwd protect = '1'><![CDATA[]]></conf_passwd>\r\n" );
}
else
{
valueXmlString.append( "<conf_passwd protect = '0'><![CDATA[]]></conf_passwd>\r\n" );
}
}
valueXmlString.append( "</Detail1>\r\n" );
} //Case 1. End
break;
}//End of switch block
valueXmlString.append( "</Root>\r\n" );
}
catch (Exception e)
{
System.out.println("Exception :SalesReturnVerifyPasswordIC :itemChanged(Document):"+ e.getMessage() + ":");
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.close();
conn = null;
}
}
catch (Exception e)
{
e.printStackTrace();
throw new ITMException(e);
}
}
System.out.println( "valueXmlString.toString()>>>>>>>::"+valueXmlString.toString());
return valueXmlString.toString();
}
private String checkNull(String input)
{
if ( input == null )
{
input = "";
}
return input.trim();
}
}
package ibase.webitm.ejb.dis;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import java.rmi.RemoteException;
import org.w3c.dom.Document;
@javax.ejb.Local
public interface SalesReturnVerifyPasswordICLocal extends ValidatorLocal
{
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 currFormDataDom, Document hdrDataDom, Document allFormDataDom, String objContext, String currentColumn,String editFlag, String xtraParams ) throws RemoteException, ITMException;
}
package ibase.webitm.ejb.dis;
import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import java.rmi.RemoteException;
import org.w3c.dom.Document;
@javax.ejb.Remote
public interface SalesReturnVerifyPasswordICRemote extends ValidatorRemote
{
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 currFormDataDom, Document hdrDataDom, Document allFormDataDom, String objContext, String currentColumn,String editFlag, String xtraParams ) throws RemoteException, ITMException;
}
/* Developed By Pavan Rane.
* Date : 12-JUN-2019
* Component Name : SalesReturnVerifyPasswordPrc
*/
package ibase.webitm.ejb.dis;
import ibase.utility.E12GenericUtility;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ProcessEJB;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import javax.ejb.Stateless;
import javax.xml.rpc.ParameterMode;
import org.apache.axis.client.Call;
import org.apache.axis.client.Service;
import org.apache.axis.encoding.XMLType;
import org.w3c.dom.Document;
/**
* Session Bean implementation class EmpMaritalStatusConfPrc
*/
@Stateless
public class SalesReturnVerifyPasswordPrc extends ProcessEJB implements SalesReturnVerifyPasswordPrcRemote, SalesReturnVerifyPasswordPrcLocal
{
E12GenericUtility genericUtility = new E12GenericUtility();
public String process() throws RemoteException, ITMException {
return "";
}
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException, ITMException {
String retString = "";
Document detailDom = null;
Document headerDom = null;
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);
}
retString = process(headerDom, detailDom, windowName, xtraParams);
} catch (Exception e) {
System.out.println("Exception :SalesReturnVerifyPasswordPrc :process(String):" + e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
}
return retString;
}
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException, ITMException
{
System.out.println("-----------Calling SalesReturnVerifyPasswordIC----process(Documents)----------");
String returnString = "", tranId = "", sql = "", lsPasswd = "", lsConfirm = "", lsEntPasswd = "";
String lsPwdVerified = "N";
boolean isError = false;
Connection conn = null;
ITMDBAccessEJB itmDBAccess = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String objName = "", compType = "";
try {
conn = getConnection();
conn.setAutoCommit(false);
itmDBAccess = new ITMDBAccessEJB();
objName = "salesreturn_retn";
tranId = genericUtility.getColumnValue("tran_id", detailDom);
System.out.println("SalesReturn No: # "+tranId+"]");
if (tranId == null || tranId.trim().length() <= 0)
{
returnString = itmDBAccess.getErrorString("", "VTTRNNULL", "", "", conn);
return returnString;
} else
{
sql = "select conf_passwd, confirmed from sreturn where tran_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if (rs.next()) {
lsPasswd = checkNull(rs.getString("conf_passwd"));
lsConfirm = checkNull(rs.getString("confirmed"));
}
pstmt.close();
pstmt = null;
rs.close();
rs = null;
System.out.println("@V@ PAVAN lsPasswd :- [" + lsPasswd + "]");
System.out.println("@V@ PAVAN lsConfirm :- [" + lsConfirm + "]");
if ("Y".equalsIgnoreCase(lsConfirm)) {
returnString = itmDBAccess.getErrorString("", "VTMCONF1", "", "", conn);
return returnString;
}
else
{
if (lsPasswd != null && lsPasswd.trim().length() > 0)
{
lsEntPasswd = checkNull(genericUtility.getColumnValue("conf_passwd", detailDom));
System.out.println("@V@ PAVAN lsEntPasswd :- [" + lsEntPasswd + "]");
if (lsEntPasswd == null || lsEntPasswd.trim().length() <= 0 || !(lsEntPasswd.equals(lsPasswd)))
{
returnString = itmDBAccess.getErrorString("", "VPINVDPSWD", "", "", conn);
return returnString;
} else
{
if(lsEntPasswd.equals(lsPasswd))
{
lsPwdVerified = "Y";
}
}
} /*else {
lsPwdVerified = "Y";
}*/
if ("Y".equalsIgnoreCase(lsPwdVerified)) {
sql = "select comp_type from system_events where obj_name = ? and EVENT_CODE = 'pre_confirm';";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, objName);
rs = pstmt.executeQuery();
if (rs.next()) {
compType = checkNull(rs.getString("comp_type"));
}
pstmt.close();
pstmt = null;
rs.close();
rs = null;
// conn.commit();
System.out.println("@V@ Commiting befor SalesReturnConfirm 144");
if ("JB".equalsIgnoreCase(compType)) {
// SalesReturnConf sReturnConf= new SalesReturnConf();
// returnString = sReturnConf.actionConfirm(tranId, xtraParams, "", "Y", connection);
} else
{
returnString = sReturnConfirm(tranId, objName, xtraParams, conn);
}
}
}
} // TRAN_ID NOT NULL
if (returnString.length() > 0 && returnString.indexOf("VTCONF") > -1)
{
returnString = itmDBAccess.getErrorString("", "PRCSUCES", "", "", conn);
} else
{
isError = true;
System.out.println("SalesReturnVerifyPasswordPrc isError ::[" + isError + "]");
// returnString = itmDBAccess.getErrorString("", "PRCFAIL", "", "", connection);
}
} catch (Exception e) {
isError = true;
System.out.println("Exception :SalesReturnVerifyPasswordPrc :process(Documnet):"+ e.getMessage() + ":");
e.printStackTrace();
throw new ITMException(e);
} finally {
System.out.println("Finally Closing Connection....");
try {
if (isError) {
conn.rollback();
System.out.println("SalesReturnVerifyPasswordPrc connection rollback");
} else {
conn.commit();
System.out.println("SalesReturnVerifyPasswordPrc connection committed");
}
if (conn != null) {
conn.close();
conn = null;
}
} catch (Exception e) {
returnString = e.getMessage();
e.printStackTrace();
}
}
System.out.println("errString...:: " + returnString);
return returnString;
}
private String checkNull(String input) {
if (input == null || ("null").equalsIgnoreCase(input.trim())) {
input = "";
} else {
input = input.trim();
}
return input;
}
public String sReturnConfirm(String tranId, String objName, String xtraParams, Connection conn)
throws ITMException {
String methodName = "";
String compName = "";
String retString = "";
String serviceCode = "";
String serviceURI = "";
String actionURI = "";
String sql = "";
PreparedStatement pStmt = null;
ResultSet rs = null;
try {
System.out.println("sReturnConfirm tranId:[" + tranId + "] objName:["+objName+"]xtraParams: ["+xtraParams+"]");
methodName = "gbf_post";
actionURI = "http://NvoServiceurl.org/" + methodName;
sql = "SELECT SERVICE_CODE,COMP_NAME FROM SYSTEM_EVENTS WHERE OBJ_NAME = ? AND EVENT_CODE = 'pre_confirm' ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, objName);
rs = pStmt.executeQuery();
if (rs.next()) {
serviceCode = rs.getString("SERVICE_CODE");
compName = rs.getString("COMP_NAME");
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
sql = "SELECT SERVICE_URI FROM SYSTEM_EVENT_SERVICES WHERE SERVICE_CODE = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, serviceCode);
rs = pStmt.executeQuery();
if (rs.next()) {
serviceURI = rs.getString("SERVICE_URI");
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
Service service = new Service();
Call call = (Call) service.createCall();
call.setTargetEndpointAddress(new java.net.URL(serviceURI));
call.setOperationName(new javax.xml.namespace.QName("http://NvoServiceurl.org", methodName));
call.setUseSOAPAction(true);
call.setSOAPActionURI(actionURI);
Object[] aobj = new Object[4];
call.addParameter(new javax.xml.namespace.QName("http://NvoServiceurl.org", "component_name"),
XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter(new javax.xml.namespace.QName("http://NvoServiceurl.org", "tab_xml_data_1"),
XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter(new javax.xml.namespace.QName("http://NvoServiceurl.org", "tab_xml_data__all"),
XMLType.XSD_STRING, ParameterMode.IN);
call.addParameter(new javax.xml.namespace.QName("http://NvoServiceurl.org", "xtra_params"),
XMLType.XSD_STRING, ParameterMode.IN);
String nullString = "";
if (tranId == null) {
tranId = "";
}
System.out.println("compName [" + compName + "]tab_xml_data_1 [" + tranId.trim() + "tab_xml_data__all ["
+ nullString + "\n]");
aobj[0] = new String(compName);
aobj[1] = new String(tranId.trim() + "\tR\n");
aobj[3] = new String(xtraParams);
aobj[2] = new String(tranId.trim() + "\tR\n");// forcedflag
call.setReturnType(XMLType.XSD_STRING);
retString = (String) call.invoke(aobj);
System.out.println("Return string from NVO is:==>[" + retString + "]");
} catch (Exception e) {
e.printStackTrace();
throw new ITMException(e);
} finally {
try {
if (rs != null) {
rs.close();
rs = null;
}
if (pStmt != null) {
pStmt.close();
pStmt = null;
}
} catch (Exception e) {
}
}
return retString;
}
}
package ibase.webitm.ejb.dis;
import ibase.webitm.ejb.ProcessLocal;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import javax.ejb.Local;
import org.w3c.dom.Document;
@Local
public interface SalesReturnVerifyPasswordPrcLocal extends ProcessLocal
{
public String process() 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;
}
package ibase.webitm.ejb.dis;
import ibase.webitm.ejb.ProcessRemote;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException;
import javax.ejb.Remote;
import org.w3c.dom.Document;
@Remote
public interface SalesReturnVerifyPasswordPrcRemote extends ProcessRemote
{
public String process() 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;
}
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