Request Id: D16EBAS004

EJB files of Purchase Order,Sales Order,Sales Order Amendment & Sales  Return workflows.


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@103259 ce508802-f39f-4f6c-b175-0d175dae99d5

webitm-dis/ibase/webitm/ejb/dis/SaleReturnConfWF.java

+/********************************************************
+	Title : SaleReturnConfWF[D16EBAS004]
+	Date  : 31/08/16
+	Developer: Aniket
+	
+ ********************************************************/
+package ibase.webitm.ejb.dis;
+
+import ibase.system.config.ConnDriver;
+import ibase.utility.E12GenericUtility;
+import ibase.webitm.utility.ITMException;
+
+import java.net.URL;
+import java.rmi.RemoteException;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+import javax.ejb.Stateless;
+import javax.xml.namespace.QName;
+import javax.xml.rpc.ParameterMode;
+
+import org.apache.axis.client.Call;
+import org.apache.axis.client.Service;
+import org.apache.axis.encoding.XMLType;
+
+
+@Stateless
+public class SaleReturnConfWF implements SaleReturnConfWFRemote, SaleReturnConfWFLocal {
+
+	public String confirm(String tran_id, String empCodeAprv, String loginSiteCode, String keyFlag) throws RemoteException, ITMException {
+		System.out.println("SaleReturnConfWF confirm method invocation");
+		System.out.println("Parameters ::: qorder_no["+tran_id+"],empCodeAprv["+empCodeAprv+"],keyFlag["+keyFlag+"]");
+		String loginCode = "";
+		String xtraParams = "";
+		String retString = "";
+		Connection conn = null;
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		ConnDriver connDriver = new ConnDriver();
+		E12GenericUtility genericUtility = null;
+		
+		try {
+			conn = connDriver.getConnectDB("DriverITM");
+			connDriver = null;
+			conn.setAutoCommit(false);
+			empCodeAprv = empCodeAprv == null ? "" : empCodeAprv.trim();
+			
+			String methodName = "";
+			String compName = "";
+			String businessObj = "salesreturn_retn";
+			String eventCode = "pre_confirm";
+			String serviceCode = "";
+			String serviceURI = "";
+			String actionURI = "";
+
+			sql = " select code from users where emp_code = ? ";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1, empCodeAprv);
+			rs = pstmt.executeQuery();
+			if (rs.next()) {
+				loginCode = rs.getString(1);
+			}
+
+			loginCode = loginCode == null ? "" : loginCode.trim();
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+
+			xtraParams = "loginCode=" + loginCode + "~~" + "loginSiteCode=" + loginSiteCode + "~~" + "loginEmpCode=" + empCodeAprv;
+
+			genericUtility = new E12GenericUtility();
+			methodName = "gbf_post";
+			actionURI = "http://NvoServiceurl.org/" + methodName;
+
+			sql = "SELECT SERVICE_CODE,COMP_NAME FROM SYSTEM_EVENTS WHERE OBJ_NAME = ? AND EVENT_CODE = ? ";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1, businessObj);
+			pstmt.setString(2, eventCode);
+			rs = pstmt.executeQuery();
+			if (rs.next()) {
+				serviceCode = rs.getString("SERVICE_CODE");
+				compName = rs.getString("COMP_NAME");
+			}
+			serviceCode = serviceCode == null ? "" : serviceCode.trim();
+			compName = compName == null ? "" : compName.trim();
+			System.out.println("serviceCode = " + serviceCode + " compName " + compName);
+
+			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");
+			}
+			serviceURI = serviceURI == null ? "" : serviceURI.trim();
+			System.out.println("serviceURI = " + serviceURI);
+			
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+
+			Service service = new Service();
+			Call call = (Call) service.createCall();
+			call.setTargetEndpointAddress(new URL(serviceURI));
+			call.setOperationName(new QName("http://NvoServiceurl.org", methodName));
+			call.setUseSOAPAction(true);
+			call.setSOAPActionURI(actionURI);
+			Object[] aobj = new Object[4];
+
+			call.addParameter(new QName("http://NvoServiceurl.org", "component_name"), XMLType.XSD_STRING, ParameterMode.IN);
+			call.addParameter(new QName("http://NvoServiceurl.org", "tran_id"), XMLType.XSD_STRING, ParameterMode.IN);
+			call.addParameter(new QName("http://NvoServiceurl.org", "xtra_params"), XMLType.XSD_STRING, ParameterMode.IN);
+			call.addParameter(new QName("http://NvoServiceurl.org", "forced_flag"), XMLType.XSD_STRING, ParameterMode.IN);
+
+			aobj[0] = new String(compName);
+			aobj[1] = new String(tran_id);
+			aobj[2] = new String(xtraParams);
+			System.out.println("@@@@@@@@@@loginEmpCode:" + genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode") + ":");
+			call.setReturnType(XMLType.XSD_STRING);
+			retString = (String) call.invoke(aobj);
+			System.out.println("Confirm Complete @@@@@@@@@@@Return string from NVO is:==>[" + retString + "]");
+
+			if ((retString.indexOf("success") > -1) || (retString.indexOf("Success") > -1) || (retString.indexOf("VTSUCC1") > -1)) {
+				System.out.println("Transaction Successfull");
+				retString = "Y";
+			} else {
+				retString = "N";
+				System.out.println("Exception while calling WSR component");
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+			System.out.println("Exeption occured");
+			throw new ITMException(e);
+		} finally {
+			if (conn != null) {
+				try {
+					conn.close();
+					conn = null;
+				} catch (SQLException e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		System.out.println("Return string from confirm method is: "+retString);
+		return retString;
+	}
+
+   
+
+}

webitm-dis/ibase/webitm/ejb/dis/SaleReturnConfWFLocal.java

+package ibase.webitm.ejb.dis;
+import ibase.webitm.utility.ITMException;
+
+import java.rmi.RemoteException;
+
+import javax.ejb.Local;
+
+@Local
+public interface SaleReturnConfWFLocal {
+	public String confirm(String tran_id, String empCodeAprv, String loginSiteCode, String keyFlag) throws RemoteException, ITMException;
+}

webitm-dis/ibase/webitm/ejb/dis/SaleReturnConfWFRemote.java

+package ibase.webitm.ejb.dis;
+import ibase.webitm.utility.ITMException;
+
+import java.rmi.RemoteException;
+
+import javax.ejb.Remote;
+
+@Remote
+public interface SaleReturnConfWFRemote {
+	public String confirm(String tran_id, String empCodeAprv, String loginSiteCode, String keyFlag) throws RemoteException, ITMException;
+}

webitm-dis/ibase/webitm/ejb/dis/adv/PorderConfWF.java

+/********************************************************
+	Title : PorderConfWF[D16EBAS004]
+	Date  : 25/08/16
+	Developer: Aniket
+	
+ ********************************************************/
+
+package ibase.webitm.ejb.dis.adv;
+
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import ibase.webitm.ejb.dis.adv.PorderConf;
+import javax.ejb.Stateless;
+
+@Stateless
+public class PorderConfWF implements PorderConfWFRemote, PorderConfWFLocal {
+
+	public String confirm(String purcOrder, String xtraParams, String forcedFlag) throws RemoteException, ITMException {
+		System.out.println("PorderConfWF confirm method called>>>>>>>>>>>>>>>>>>>");
+		String retString = "N", errString = "";
+		PorderConf porderConf = null;
+		
+		try {
+			porderConf = new PorderConf();
+			errString = porderConf.confirm(purcOrder, xtraParams, forcedFlag);
+			if(errString != null && errString.trim().length() > 0)
+			{
+				if(errString.indexOf("VTCNFSUCC") > -1)
+				{
+					retString = "Y";
+					System.out.println("@@@@ POrder Workflow Transaction Confirmed... ");
+				}
+				else
+				{
+					System.out.println("@@@@ POrder Workflow Error Occured... ");
+				}
+			}
+		} catch (Exception e) {
+			System.out.println("Exception Occured in PorderConfWF confirm");
+			e.printStackTrace();
+		}
+		System.out.println("returnString>>>> "+retString);
+		return retString;
+	}
+}

webitm-dis/ibase/webitm/ejb/dis/adv/PorderConfWFLocal.java

+package ibase.webitm.ejb.dis.adv;
+
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import javax.ejb.Local;
+
+@Local
+public interface PorderConfWFLocal {
+	public String confirm(String purcOrder, String xtraParams, String forcedFlag) throws RemoteException, ITMException;
+}

webitm-dis/ibase/webitm/ejb/dis/adv/PorderConfWFRemote.java

+package ibase.webitm.ejb.dis.adv;
+
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import javax.ejb.Remote;
+
+@Remote
+public interface PorderConfWFRemote {
+	public String confirm(String purcOrder, String xtraParams, String forcedFlag) throws RemoteException, ITMException;
+}

webitm-dis/ibase/webitm/ejb/dis/adv/SOrderAmdConfWF.java

+/********************************************************
+	Title : SOrderAmdConfWF[D16EBAS004]
+	Date  : 25/08/16
+	Developer: Aniket
+	
+ ********************************************************/
+package ibase.webitm.ejb.dis.adv;
+
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import javax.ejb.Stateless;
+import ibase.webitm.ejb.dis.adv.SOrderAmdConf;
+
+
+@Stateless
+public class SOrderAmdConfWF implements SOrderAmdConfWFRemote, SOrderAmdConfWFLocal {
+   
+	public String confirm(String saleOrderAmd, String xtraParams, String forcedFlag) throws RemoteException, ITMException {
+		System.out.println("SOrderAmdConfWF confirm method called>>>>>>>>>>>>>>>>>>>");
+		String retString = "N", errString = "";
+		SOrderAmdConf sOrdAmdConf = null;
+		
+		try {
+			sOrdAmdConf = new SOrderAmdConf();
+			errString = sOrdAmdConf.confirm(saleOrderAmd, xtraParams, forcedFlag);
+			if(errString != null && errString.trim().length() > 0)
+			{
+				if(errString.indexOf("VTCNFSUCC") > -1)
+				{
+					retString = "Y";
+					System.out.println("@@@@ SOrderAmd Workflow Transaction Confirmed... ");
+				}
+				else
+				{
+					System.out.println("@@@@ SOrderAmd Workflow Error Occured... ");
+				}
+			}
+		} catch (Exception e) {
+			System.out.println("Exception Occured in SOrderAmdConfWF confirm");
+			e.printStackTrace();
+		}
+		System.out.println("returnString>>>> "+retString);
+		return retString;
+	}
+	}

webitm-dis/ibase/webitm/ejb/dis/adv/SOrderAmdConfWFLocal.java

+package ibase.webitm.ejb.dis.adv;
+import java.rmi.RemoteException;
+import ibase.webitm.utility.ITMException;
+import javax.ejb.Local;
+
+@Local
+public interface SOrderAmdConfWFLocal {
+	public String confirm(String saleOrderAmd, String xtraParams, String forcedFlag) throws RemoteException, ITMException;
+}

webitm-dis/ibase/webitm/ejb/dis/adv/SOrderAmdConfWFRemote.java

+package ibase.webitm.ejb.dis.adv;
+import java.rmi.RemoteException;
+import ibase.webitm.utility.ITMException;
+import javax.ejb.Remote;
+
+@Remote
+public interface SOrderAmdConfWFRemote {
+	public String confirm(String saleOrderAmd, String xtraParams, String forcedFlag) throws RemoteException, ITMException;
+}

webitm-dis/ibase/webitm/ejb/dis/adv/SorderConfWF.java

+/********************************************************
+	Title : SorderConfWF[D16EBAS004]
+	Date  : 25/08/16
+	Developer: Aniket
+	
+ ********************************************************/
+
+package ibase.webitm.ejb.dis.adv;
+
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import ibase.webitm.ejb.dis.adv.SorderConf;
+import javax.ejb.Stateless;
+
+
+@Stateless
+public class SorderConfWF implements SorderConfWFRemote, SorderConfWFLocal {
+
+	public String confirm(String saleOrder, String xtraParams, String forcedFlag) throws RemoteException, ITMException {
+		System.out.println("SOrderConfWF confirm method called>>>>>>>>>>>>>>>>>>>");
+		String retString = "N", errString = "";
+		SorderConf sorderConf = null;
+		
+		try {
+			sorderConf = new SorderConf();
+			errString = sorderConf.confirm(saleOrder, xtraParams, forcedFlag);
+			if(errString != null && errString.trim().length() > 0)
+			{
+				if(errString.indexOf("VTCNFSUCC") > -1)
+				{
+					retString = "Y";
+					System.out.println("@@@@ SOrder Workflow Transaction Confirmed... ");
+				}
+				else
+				{
+					System.out.println("@@@@ SOrder Workflow Error Occured... ");
+				}
+			}
+		} catch (Exception e) {
+			System.out.println("Exception Occured in SOrderConfWF confirm");
+			e.printStackTrace();
+		}
+		System.out.println("returnString>>>> "+retString);
+		return retString;
+	}
+}

webitm-dis/ibase/webitm/ejb/dis/adv/SorderConfWFLocal.java

+package ibase.webitm.ejb.dis.adv;
+
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import javax.ejb.Local;
+
+@Local
+public interface SorderConfWFLocal {
+	public String confirm(String saleOrder, String xtraParams, String forcedFlag) throws RemoteException, ITMException;
+}

webitm-dis/ibase/webitm/ejb/dis/adv/SorderConfWFRemote.java

+package ibase.webitm.ejb.dis.adv;
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import javax.ejb.Remote;
+
+@Remote
+public interface SorderConfWFRemote {
+	public String confirm(String saleOrder, String xtraParams, String forcedFlag) throws RemoteException, ITMException;
+}