Request Id:W16LSER003,W16LSER006

Source Files of Pricelist Generation and Sales Return Workflow.


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

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

+package ibase.webitm.ejb.dis;
+
+import ibase.utility.E12GenericUtility;
+import ibase.webitm.ejb.XML2DBEJB;
+import ibase.webitm.utility.GenerateXmlFromDB;
+import ibase.webitm.utility.ITMException;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.w3c.dom.Node;
+import org.w3c.dom.NodeList;
+
+public class GenericWorkflowClass {
+	public String invokeWorkflow(Connection conn, String tranId, String xtraParams, String winName, String objName) throws ITMException {
+		E12GenericUtility genericUtility = new E12GenericUtility();
+		Document domAll = null;
+		NodeList nodeList = null;
+		Node node = null;
+		Element nodeElement = null;
+		String sql = "";
+		PreparedStatement pStmt = null;
+		ResultSet rs = null;
+		String retString = "";
+		String wrkflwInit = "";
+		String refSer = "";
+		String nodeName = "";
+		try {
+			XML2DBEJB xml2dbObj = new XML2DBEJB();
+			GenerateXmlFromDB generateXmlFromDB = new GenerateXmlFromDB();
+			String retXml = generateXmlFromDB.getXMLData(winName, tranId, conn, true, true);
+			retXml = retXml.replace("<Root>", "");
+			retXml = retXml.replace("</Root>", "");
+			if ((retXml != null) && (retXml.trim().length() > 0)) {
+				domAll = genericUtility.parseString(retXml);
+			}
+			nodeList = domAll.getElementsByTagName("Detail1");
+			node = nodeList.item(0);
+			if (node != null) {
+				objName = node.getAttributes().getNamedItem("objName").getNodeValue();
+				nodeList = node.getChildNodes();
+				int nodeListLength = nodeList.getLength();
+				for (int i = 0; i < nodeListLength; i++) {
+					node = nodeList.item(i);
+					if (node != null) {
+						nodeName = node.getNodeName();
+					}
+
+					if ("wf_status".equalsIgnoreCase(nodeName)) {
+						if (node.getFirstChild() != null) {
+							node.getFirstChild().setNodeValue("S");
+						} else {
+							nodeElement = (Element) node;
+							nodeElement.appendChild(domAll.createCDATASection("S"));
+						}
+					}
+				}
+			}
+			nodeList = domAll.getElementsByTagName("DocumentRoot");
+			node = nodeList.item(0);
+
+			sql = "SELECT WRKFLW_INIT,REF_SER FROM TRANSETUP WHERE TRAN_WINDOW = 'w_" + objName + "'";
+			pStmt = conn.prepareStatement(sql);
+			rs = pStmt.executeQuery();
+			if (rs.next()) {
+				wrkflwInit = rs.getString("WRKFLW_INIT") == null ? "" : rs.getString("WRKFLW_INIT");
+				refSer = rs.getString("REF_SER") == null ? "" : rs.getString("REF_SER");
+			}
+			if (rs != null) {
+				rs.close();
+				rs = null;
+			}
+			if (pStmt != null) {
+				pStmt.close();
+				pStmt = null;
+			}
+
+			String entityCodeInit = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
+			retString = xml2dbObj.invokeWorkflowExternal(domAll, entityCodeInit, wrkflwInit, objName, refSer, tranId);
+			System.out.println("retString From xml2dbObj.invokeWorkflowExternal --->" + retString);
+		} catch (Exception ex) {
+			ex.printStackTrace();
+			try {
+				if (rs != null) {
+					rs.close();
+					rs = null;
+				}
+				if (pStmt != null) {
+					pStmt.close();
+					pStmt = null;
+				}
+			} catch (SQLException sqlEx) {
+				System.out.println("Exception in Finally " + sqlEx.getMessage());
+				sqlEx.printStackTrace();
+			}
+		} finally {
+			try {
+				if (rs != null) {
+					rs.close();
+					rs = null;
+				}
+				if (pStmt != null) {
+					pStmt.close();
+					pStmt = null;
+				}
+			} catch (SQLException sqlEx) {
+				System.out.println("Exception in Finally " + sqlEx.getMessage());
+				sqlEx.printStackTrace();
+			}
+		}
+		return "success";
+	}
+}
\ No newline at end of file

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

+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 java.text.SimpleDateFormat;
+import java.util.Calendar;
+
+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;
+
+
+public class PricelistGenerationWF {
+
+	public String confirm(String tran_id, String empCodeAprv, String loginSiteCode, String keyFlag, String remarks) throws RemoteException, ITMException {
+		System.out.println("PricelistGenerationWF confirm ::: tran_id["+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;
+		loginSiteCode = checkNull(loginSiteCode);
+		
+		if("C".equalsIgnoreCase(keyFlag) || "R".equalsIgnoreCase(keyFlag)){
+			retString = updateWfStatus(tran_id, empCodeAprv, loginSiteCode, keyFlag, remarks);
+		}
+		else{
+		   try {
+				conn = connDriver.getConnectDB("DriverITM");
+				connDriver = null;
+				conn.setAutoCommit(false);
+				empCodeAprv = empCodeAprv == null ? "" : empCodeAprv.trim();
+				
+				String methodName = "";
+				String compName = "";
+				String businessObj = "pricelist_tran";
+				String eventCode = "pre_confirm";
+				String serviceCode = "";
+				String serviceURI = "";
+				String actionURI = "";
+	
+				sql = " select site_code__def,code from users where emp_code = ? ";
+				pstmt = conn.prepareStatement(sql);
+				pstmt.setString(1, empCodeAprv);
+				rs = pstmt.executeQuery();
+				if (rs.next()) {
+					loginCode     = checkNull(rs.getString("code"));
+					loginSiteCode = checkNull(rs.getString("site_code__def"));
+				}
+	
+				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 in PricelistGenerationWF 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 PricelistGenerationWF confirm method is: "+retString);
+		return retString;
+	}
+
+	public String updateWfStatus(String tran_id,String empCodeAprv, String loginSiteCode, String wfStatus, String remarks) {
+		String  retString = "";
+		Connection conn = null;
+		ConnDriver connDriver = new ConnDriver();
+		PreparedStatement pStmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		int cnt = 0;
+		boolean isError = false;
+		wfStatus = checkNull(wfStatus);
+		remarks = checkNull(remarks);
+		try
+		{
+			conn = connDriver.getConnectDB("DriverITM");
+			conn.setAutoCommit(false);
+			connDriver = null;
+			if ("C".equalsIgnoreCase(wfStatus) || "R".equalsIgnoreCase(wfStatus)) {
+				sql = "UPDATE PRICELIST_HDR SET WF_STATUS = '"+wfStatus+"',REMARKS = '"+remarks+"' WHERE TRAN_ID = ?";
+				pStmt = conn.prepareStatement(sql);
+				pStmt.setString(1, tran_id);
+				cnt = pStmt.executeUpdate();
+			} 
+			else{
+				System.out.println("Workflow In Progress");
+			}
+		}
+		catch (Exception e)
+		{
+			isError = true;
+			System.out.println("Exception : PricelistGenerationWF : updateWfStatus() : ==>\n" + e.getMessage());
+			e.printStackTrace();
+		}
+		finally
+		{
+			try
+			{
+				if(rs !=null)
+    			{
+    				rs.close();rs=null;
+    			}
+    			if(pStmt != null)
+                {
+                	pStmt.close();pStmt = null;
+                }
+    			if (conn != null) {
+    				try {
+    					if (isError || !(cnt > 0)) {
+    						conn.rollback();
+    						retString = "N";
+    						System.out.println("PricelistGenerationWF updateWfStatus: Connection Rollback");
+    					} else {
+    						conn.commit();
+    						retString = "Y";
+    						System.out.println("PricelistGenerationWF updateWfStatus: Connection Commit");
+    					}
+    					conn.close();
+    					conn = null;
+    				} catch (Exception e) {
+    					e.printStackTrace();
+    				}
+    			}
+			}
+			catch(SQLException sqlEx)
+			{
+				System.out.println("Exception in updateWfStatus() Finally "+sqlEx.getMessage());
+				sqlEx.printStackTrace();
+			}
+		}
+		return retString;
+	}
+	
+	public String escalate(String tranId, String empCodeAprv, String xmlDataAll, String processId, String roleCode, String activityId) throws ITMException, Exception {
+		System.out.println("Parameters ::: tranId["+tranId+"],empCodeAprv["+empCodeAprv+"],xmlDataAll["+xmlDataAll+"],processId["+processId+"],roleCode["+roleCode+"],activityId["+activityId+"]");
+		String retString = "";
+		Boolean isError = false;
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		E12GenericUtility genericUtility = null;
+		SimpleDateFormat  simpleDateFormat = null;
+		String currDate = "";
+		String signStatus = "", userCode = "",processInfo[] = null;
+		int resultCnt = 0;
+		Connection conn = null;
+		ConnDriver connDriver = null;
+		
+		try
+		{
+			connDriver = new ConnDriver();
+			genericUtility = new E12GenericUtility();
+			conn = connDriver.getConnectDB("DriverITM");
+			conn.setAutoCommit(false);
+			connDriver = null;
+			simpleDateFormat  = new SimpleDateFormat(genericUtility.getApplDateTimeFormat());
+			currDate          = simpleDateFormat.format( Calendar.getInstance().getTime() );
+			currDate          = genericUtility.getValidDateTimeString( currDate, genericUtility.getApplDateTimeFormat(),genericUtility.getDBDateTimeFormat() ) ;
+
+			sql = "select SIGN_STATUS from OBJ_SIGN_TRANS "
+				+ "WHERE ltrim(rtrim(REF_SER)) = 'P-LST' AND ltrim(rtrim(REF_ID)) = ? AND ltrim(rtrim(ROLE_CODE__SIGN)) = ? "
+				+ "AND SIGN_STATUS = 'U'";
+				
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1, tranId);
+			pstmt.setString(2, roleCode);
+			rs = pstmt.executeQuery();
+			
+			if (rs.next()) 
+			{
+				signStatus = rs.getString("SIGN_STATUS");
+			}
+			System.out.println("signStatus = " + signStatus);
+
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+			
+			if("U".equalsIgnoreCase(signStatus)){
+				
+				sql = "select code from users where emp_code = ? ";
+				pstmt = conn.prepareStatement(sql);
+				pstmt.setString(1, empCodeAprv);
+				rs = pstmt.executeQuery();
+				
+				if (rs.next()) 
+				{
+					userCode = rs.getString("code");
+				}
+				userCode = userCode == null ? "" : userCode.trim();
+	
+				rs.close();
+				rs = null;
+				pstmt.close();
+				pstmt = null;
+				
+				sql = "UPDATE OBJ_SIGN_TRANS "
+						+ "SET SIGN_DATE = ?, USER_ID__SIGN = ?, SIGN_REMARKS = 'HR_SPAN is over', SIGN_STATUS = 'V', EMP_CODE = ? "
+						+ "WHERE ltrim(rtrim(REF_SER)) = 'P-LST' AND ltrim(rtrim(REF_ID)) = ? AND ltrim(rtrim(ROLE_CODE__SIGN)) = ? "
+						+ "AND SIGN_STATUS = 'U'";
+						
+				pstmt = conn.prepareStatement(sql);
+				pstmt.setTimestamp(1,java.sql.Timestamp.valueOf(currDate));
+				pstmt.setString(2, userCode);
+				pstmt.setString(3, empCodeAprv);
+				pstmt.setString(4, tranId);
+				pstmt.setString(5, roleCode);
+				
+				resultCnt += pstmt.executeUpdate();
+				pstmt.close();
+				pstmt = null;
+				System.out.println("Update Successfully:"+resultCnt);
+				
+				processInfo = processId.split(":");
+				sql = "UPDATE WF_PRC_STATUS "
+						+ "SET STATUS_DATE = ?, PROCESS_STATUS = 4, ERR_STATUS = '0', "
+						+ "STATUS_REMARKS='Escalated -> Completing :"+processId+" Invoked :"+processId+"' "
+						+ "WHERE ltrim(rtrim(REF_SER)) = 'P-LST' AND REF_ID = ? AND PROCESS_ID = ? AND INSTANCE_ID = ? AND ACTIVITY_ID = ? AND PROCESS_STATUS != 3";
+				
+				pstmt = conn.prepareStatement(sql);
+				pstmt.setTimestamp(1,java.sql.Timestamp.valueOf(currDate));
+				pstmt.setString(2, tranId);
+				pstmt.setString(3, processInfo[0]);
+				pstmt.setString(4, processInfo[1]);
+				pstmt.setString(5, activityId);
+				resultCnt += pstmt.executeUpdate();
+				pstmt.close();
+				pstmt = null;
+				System.out.println("Update Successfully:"+resultCnt);
+			} 
+			else 
+			{
+				retString = "N";
+			}
+		}
+		catch (Exception e) {
+			System.out.println("Exception: PricelistGenerationWF escalate method ..> " + e.getMessage());
+			isError = true;
+			throw new ITMException(e);
+		} finally {
+			if(rs !=null)
+			{
+				rs.close();rs=null;
+			}
+			if(pstmt != null)
+            {
+				pstmt.close();pstmt = null;
+            }
+			if (conn != null) {
+				try {
+					if (isError || !(resultCnt > 0)) {
+						conn.rollback();
+						retString = "N";
+						System.out.println("PricelistGenerationWF escalate: Connection Rollback");
+					} else {
+						conn.commit();
+						retString = "Y";
+						System.out.println("PricelistGenerationWF escalate: Connection Commit");
+					}
+					conn.close();
+					conn = null;
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		return retString;
+	}
+	
+	public String approverSignStatusUpdate(String tranId, String empCodeAprv, String xmlDataAll, String processId, String roleCode, String activityId, String signStatusFlag) throws ITMException, Exception {
+		System.out.println("Parameters ::: tranId["+tranId+"],empCodeAprv["+empCodeAprv+"],xmlDataAll["+xmlDataAll+"],processId["+processId+"],roleCode["+roleCode+"],signStatusFlag["+signStatusFlag+"]");
+		String retString = "",signRemarks = "",empName = "";
+		Boolean isError = false;
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		E12GenericUtility genericUtility = null;
+		SimpleDateFormat  simpleDateFormat = null;
+		String currDate = "";
+		String userCode = "",processInfo[] = null;
+		int resultCnt = 0;
+		Connection conn = null;
+		ConnDriver connDriver = null;
+		empCodeAprv = checkNull(empCodeAprv);
+		tranId = checkNull(tranId);
+		processId = checkNull(processId);
+		signStatusFlag = checkNull(signStatusFlag);
+		roleCode = checkNull(roleCode);
+		
+		try
+		{
+			connDriver = new ConnDriver();
+			genericUtility = new E12GenericUtility();
+			conn = connDriver.getConnectDB("DriverITM");
+			conn.setAutoCommit(false);
+			connDriver = null;
+			simpleDateFormat  = new SimpleDateFormat(genericUtility.getApplDateTimeFormat());
+			currDate          = simpleDateFormat.format( Calendar.getInstance().getTime() );
+			currDate          = genericUtility.getValidDateTimeString( currDate, genericUtility.getApplDateTimeFormat(),genericUtility.getDBDateTimeFormat() ) ;
+			System.out.println(" approverSignStatusUpdate :: currDate :: ["+currDate+"]");
+				
+			sql = "select u.code,e.emp_fname || ' ' || e.emp_lname as emp_name from users u inner join employee e on e.emp_code = u.emp_code where e.emp_code = ? ";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1, empCodeAprv);
+			rs = pstmt.executeQuery();
+			
+			if (rs.next()) 
+			{
+				userCode = checkNull(rs.getString("code"));
+				empName  = checkNull(rs.getString("emp_name"));
+			}
+
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+			
+			if("S".equalsIgnoreCase(signStatusFlag)){
+				signRemarks = "Transaction Approved by "+empName+".";
+			}
+			else if("R".equalsIgnoreCase(signStatusFlag)){
+				signRemarks = "Transaction Rejected by "+empName+".";
+			}
+			else{
+				signRemarks = "Transaction Approved by "+empName+".";
+			}
+			
+			sql = "UPDATE OBJ_SIGN_TRANS "
+					+ "SET SIGN_DATE = ?, USER_ID__SIGN = ?, SIGN_REMARKS = '"+signRemarks+"', SIGN_STATUS = 'V', EMP_CODE = ? "
+					+ "WHERE ltrim(rtrim(REF_SER)) = 'P-LST' AND ltrim(rtrim(REF_ID)) = ? AND ltrim(rtrim(ROLE_CODE__SIGN)) = ? "
+					+ "AND SIGN_STATUS = 'U'";
+					
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setTimestamp(1,java.sql.Timestamp.valueOf(currDate));
+			pstmt.setString(2, userCode);
+			pstmt.setString(3, empCodeAprv);
+			pstmt.setString(4, tranId);
+			pstmt.setString(5, roleCode);
+			
+			resultCnt += pstmt.executeUpdate();
+			pstmt.close();
+			pstmt = null;
+			System.out.println("Update Successfully:"+resultCnt);
+			
+			processInfo = processId.split(":");
+			sql = "UPDATE WF_PRC_STATUS SET STATUS_DATE = ?, PROCESS_STATUS = 4, ERR_STATUS = '0', STATUS_REMARKS = '"+signRemarks+"' " +
+				  "WHERE ltrim(rtrim(REF_SER)) = 'P-LST' AND REF_ID = ? AND PROCESS_ID = ? AND INSTANCE_ID = ? AND ACTIVITY_ID = ? AND PROCESS_STATUS != 3";
+			
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setTimestamp(1,java.sql.Timestamp.valueOf(currDate));
+			pstmt.setString(2, tranId);
+			pstmt.setString(3, processInfo[0]);
+			pstmt.setString(4, processInfo[1]);
+			pstmt.setString(5, activityId);
+			resultCnt += pstmt.executeUpdate();
+			pstmt.close();
+			pstmt = null;
+			System.out.println("Update Successfully:"+resultCnt);
+		}
+		catch (Exception e) {
+			System.out.println("Exception: approverSignStatusUpdate method ..> " + e.getMessage());
+			isError = true;
+			throw new ITMException(e);
+		} finally {
+			if(rs !=null)
+			{
+				rs.close();rs=null;
+			}
+			if(pstmt != null)
+            {
+				pstmt.close();pstmt = null;
+            }
+			if (conn != null) {
+				try {
+					if (isError || !(resultCnt > 0)) {
+						conn.rollback();
+						retString = "N";
+						System.out.println("approverSignStatusUpdate: Connection Rollback");
+					} else {
+						conn.commit();
+						retString = "Y";
+						System.out.println("approverSignStatusUpdate: Connection Commit");
+					}
+					conn.close();
+					conn = null;
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		return retString;
+	}
+	public String checkEscalationStatus(String tranId, String empCodeAprv, String xmlDataAll, String processId, String roleCode, String activityId) throws ITMException, Exception {
+		System.out.println("checkEscalationStatus Parameters ::: tranId["+tranId+"],empCodeAprv["+empCodeAprv+"],xmlDataAll["+xmlDataAll+"],processId["+processId+"]");
+		String retString = "";
+		Boolean isError = false;
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		String sql = "",prcId = "", instanceId = "",processInfo[] = null;
+		int escalationCnt = 0, finAprvObjTransCnt = 0;
+		Connection conn = null;
+		ConnDriver connDriver = null;
+		empCodeAprv = checkNull(empCodeAprv);
+		tranId = checkNull(tranId);
+		processId = checkNull(processId);
+		roleCode = checkNull(roleCode);
+		
+		try
+		{
+			connDriver     = new ConnDriver();
+			conn           = connDriver.getConnectDB("DriverITM");
+			conn.setAutoCommit(false);
+			connDriver     = null;
+			processInfo    = processId.split(":");
+			prcId          = checkNull(processInfo[0]);
+			instanceId     = checkNull(processInfo[1]);
+			System.out.println(" checkEscalationStatus :: prcId :: ["+prcId+"]"+" instanceId: "+instanceId);
+				
+			sql = "SELECT COUNT(DISTINCT(W.ACTIVITY_ID)) AS COUNT FROM OBJ_SIGN_TRANS O INNER JOIN WF_PRC_STATUS W " +
+				  "ON O.REF_ID = W.REF_ID WHERE O.SIGN_STATUS='V' AND W.PROCESS_STATUS = 4 AND O.REF_ID ='"+tranId+"' AND W.INSTANCE_ID  = "+instanceId+" ";
+			
+			pstmt = conn.prepareStatement(sql);
+			rs = pstmt.executeQuery();
+			
+			if (rs.next()) 
+			{
+				escalationCnt = rs.getInt("COUNT");
+			}
+
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+			
+			sql = "SELECT COUNT(W.ACTIVITY_ID) AS COUNT FROM WF_PRC_STATUS W WHERE W.ACTIVITY_ID = '"+activityId+"' AND W.REF_ID ='"+tranId+"' AND W.INSTANCE_ID  = "+instanceId+" ";
+		
+			pstmt = conn.prepareStatement(sql);
+			rs = pstmt.executeQuery();
+			
+			if (rs.next()) 
+			{
+				finAprvObjTransCnt = rs.getInt("COUNT");
+			}
+	
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+			System.out.println("escalationCnt :"+escalationCnt+" finAprvObjTransCnt:"+finAprvObjTransCnt);
+			
+		}
+		catch (Exception e) {
+			System.out.println("Exception: checkEscalationStatus method ..> " + e.getMessage());
+			isError = true;
+			throw new ITMException(e);
+		} finally {
+			if(rs !=null)
+			{
+				rs.close();rs=null;
+			}
+			if(pstmt != null)
+            {
+				pstmt.close();pstmt = null;
+            }
+			if (conn != null) {
+				try {
+					if (isError || !(finAprvObjTransCnt < 1)) {
+						retString = "N";
+					} else {
+						retString = "Y";
+					}
+					conn.close();
+					conn = null;
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		return retString;
+	}
+	private String checkNull(String str) {
+		if(str == null){
+			str = "";
+		}
+		else{
+			str = str.trim();
+		}
+		return str;
+	}
+}

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

+package ibase.webitm.ejb.dis;
+
+import ibase.system.config.ConnDriver;
+import ibase.webitm.ejb.ActionHandlerEJB;
+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 java.sql.SQLException;
+
+import javax.ejb.Stateless;
+
+@Stateless
+public class PricelistGenerationWfEJB extends ActionHandlerEJB implements PricelistGenerationWfEJBLocal, PricelistGenerationWfEJBRemote {
+	public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException, ITMException {
+		System.out.println("@@@@@@@@@@@@@@@@@@@@ PricelistGenerationWfEJB @@@@@@@@@@@@@@@@");
+		String userId = "";
+		String errString = "";
+		ValidatorEJB validatorEJB = null;
+		ITMDBAccessEJB itmDBAccessEJB = null;
+		Connection conn = null;
+		PreparedStatement pStmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		String status = "",confirmed = "",retString = "";
+		String[] authencate = new String[2];
+		authencate[0] = "";
+		authencate[1] = "";
+		boolean isError = false;
+		
+		try {
+			itmDBAccessEJB = new ITMDBAccessEJB();
+			validatorEJB = new ValidatorEJB();
+			conn = getConnection();
+			conn.setAutoCommit(false);
+			userId = validatorEJB.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
+
+			System.out.println("tran_id ..> " + tranId+" userId: "+userId+" xtraParams: "+xtraParams+" forcedFlag: "+forcedFlag);
+			tranId = checkNull(tranId);
+
+			sql = " select wf_status,confirmed from pricelist_hdr where tran_id = ? ";
+
+			pStmt = conn.prepareStatement(sql);
+			pStmt.setString(1, tranId);
+			rs = pStmt.executeQuery();
+			
+			if (rs.next()) {
+				status     = rs.getString("wf_status");
+				confirmed  = rs.getString("confirmed");
+			}
+			
+			status    = checkNull(status);
+			confirmed = checkNull(confirmed);
+			closePstmtRs(pStmt, rs);
+
+			if(!"Y".equalsIgnoreCase(confirmed)){
+				if ("O".equalsIgnoreCase(status) || "R".equalsIgnoreCase(status) || "".equalsIgnoreCase(status)) {
+						GenericWorkflowClass wfGenericClass = new GenericWorkflowClass();
+						retString = wfGenericClass.invokeWorkflow(conn, tranId, xtraParams, "w_pricelist_tran", "pricelist_tran");
+						if ("success".equalsIgnoreCase(retString)) {
+							
+							sql = "UPDATE PRICELIST_HDR SET WF_STATUS = 'S' WHERE TRAN_ID = ? ";
+							pStmt = conn.prepareStatement(sql);
+							pStmt.setString(1, tranId);
+							int updCount = pStmt.executeUpdate();
+							
+							if (updCount > 0) {
+								errString = new ITMDBAccessEJB().getErrorString("", "VFMWRKFLWS", "");
+							}
+							else{
+								errString = new ITMDBAccessEJB().getErrorString("", "VFMWRKFLWF", "");
+	    						isError=true;
+							}
+						} else {
+							errString = new ITMDBAccessEJB().getErrorString("", "VFMWRKFLWF", "");
+						}
+				} 
+				else {
+					errString = new ITMDBAccessEJB().getErrorString("", "VTMWFALINT", "");
+				}
+			}
+			else{
+				errString = new ITMDBAccessEJB().getErrorString("", "VTMWFALCNF", "");
+			}
+		} catch (Exception e) {
+			isError = true;
+			System.out.println("Exception: confirm method ..> " + e.getMessage());
+			e.printStackTrace();
+			errString = itmDBAccessEJB.getErrorString("", "VFMWRKFLWF", userId);
+			throw new ITMException(e);
+		} finally {
+			if (rs != null) {
+				try {
+					rs.close();
+				} catch (SQLException e) {
+					e.printStackTrace();
+				}
+				rs = null;
+			}
+			if (pStmt != null) {
+				try {
+					pStmt.close();
+				} catch (SQLException localSQLException1) {
+				}
+				pStmt = null;
+			}
+			if (conn != null) {
+				try {
+					if (isError) {
+						conn.rollback();
+						System.out.println("PricelistGenerationWfEJB: confirm: Connection Rollback");
+					} else {
+						conn.commit();
+						System.out.println("PricelistGenerationWfEJB: confirm: Connection Commit");
+					}
+					conn.close();
+					conn = null;
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		return errString;
+	}
+
+
+	private String checkNull(String str) {
+		if(str == null){
+			str = "";
+		}
+		else{
+			str = str.trim();
+		}
+		return str;
+	}
+
+	private void closePstmtRs(PreparedStatement pStmt, ResultSet rs) {
+		if (pStmt != null) {
+			try {
+				pStmt.close();
+			} catch (SQLException localSQLException1) {
+			}
+			pStmt = null;
+		}
+		if (rs != null) {
+			try {
+				rs.close();
+			} catch (SQLException e) {
+				e.printStackTrace();
+			}
+			rs = null;
+		}
+	}
+}

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

+package ibase.webitm.ejb.dis;
+
+import ibase.webitm.ejb.ActionHandlerLocal;
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import javax.ejb.Local;
+
+@Local
+public interface PricelistGenerationWfEJBLocal extends ActionHandlerLocal {
+	public String confirm(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
+}

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

+package ibase.webitm.ejb.dis;
+
+import ibase.webitm.ejb.ActionHandlerRemote;
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import javax.ejb.Remote;
+
+@Remote
+public interface PricelistGenerationWfEJBRemote extends ActionHandlerRemote {
+	public String confirm(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
+}

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

+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 java.text.SimpleDateFormat;
+import java.util.Calendar;
+
+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;
+
+
+public class SalesReturnWF {
+
+	public String confirm(String tran_id, String empCodeAprv, String loginSiteCode, String keyFlag) throws RemoteException, ITMException {
+		System.out.println("SaleReturnWF confirm ::: tran_id["+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;
+		
+		if("C".equalsIgnoreCase(keyFlag) || "R".equalsIgnoreCase(keyFlag)){
+			retString = updateWfStatus(tran_id, empCodeAprv, loginSiteCode, keyFlag);
+		}
+		else{
+			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 in SaleReturnConfWF 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 SaleReturnConfWF confirm method is: "+retString);
+		return retString;
+	}
+
+	public String updateWfStatus(String tran_id,String empCodeAprv, String loginSiteCode, String wfStatus) {
+		String  retString = "";
+		Connection conn = null;
+		ConnDriver connDriver = new ConnDriver();
+		PreparedStatement pStmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		int cnt = 0;
+		boolean isError = false;
+		
+		try
+		{
+			conn = connDriver.getConnectDB("DriverITM");
+			conn.setAutoCommit(false);
+			connDriver = null;
+			if ("C".equalsIgnoreCase(wfStatus)) {
+				sql = "UPDATE SRETURN SET WF_STATUS = 'C' WHERE TRAN_ID = ?";
+				pStmt = conn.prepareStatement(sql);
+				pStmt.setString(1, tran_id);
+				cnt = pStmt.executeUpdate();
+			} else if("R".equalsIgnoreCase(wfStatus)){
+				sql = "UPDATE SRETURN SET WF_STATUS = 'R' WHERE TRAN_ID = ?";
+				pStmt = conn.prepareStatement(sql);
+				pStmt.setString(1, tran_id);
+				cnt = pStmt.executeUpdate();
+			}
+			else{
+				System.out.println("Workflow In Progress");
+			}
+		}
+		catch (Exception e)
+		{
+			isError = true;
+			System.out.println("Exception : SaleReturnConfWF : updateWfStatus() : ==>\n" + e.getMessage());
+			e.printStackTrace();
+		}
+		finally
+		{
+			try
+			{
+				if(rs !=null)
+    			{
+    				rs.close();rs=null;
+    			}
+    			if(pStmt != null)
+                {
+                	pStmt.close();pStmt = null;
+                }
+    			if (conn != null) {
+    				try {
+    					if (isError || !(cnt > 0)) {
+    						conn.rollback();
+    						retString = "N";
+    						System.out.println("SalesReturnWF updateWfStatus: Connection Rollback");
+    					} else {
+    						conn.commit();
+    						retString = "Y";
+    						System.out.println("SalesReturnWF updateWfStatus: Connection Commit");
+    					}
+    					conn.close();
+    					conn = null;
+    				} catch (Exception e) {
+    					e.printStackTrace();
+    				}
+    			}
+			}
+			catch(SQLException sqlEx)
+			{
+				System.out.println("Exception in updateWfStatus() Finally "+sqlEx.getMessage());
+				sqlEx.printStackTrace();
+			}
+		}
+		return retString;
+	}
+	
+	public String escalate(String tranId, String empCodeAprv, String xmlDataAll, String processId, String roleCode, String activityId) throws ITMException, Exception {
+		System.out.println("Parameters ::: tranId["+tranId+"],empCodeAprv["+empCodeAprv+"],xmlDataAll["+xmlDataAll+"],processId["+processId+"],roleCode["+roleCode+"],activityId["+activityId+"]");
+		String retString = "";
+		Boolean isError = false;
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		E12GenericUtility genericUtility = null;
+		SimpleDateFormat  simpleDateFormat = null;
+		String currDate = "";
+		String signStatus = "", userCode = "",processInfo[] = null;
+		int resultCnt = 0;
+		Connection conn = null;
+		ConnDriver connDriver = null;
+		
+		try
+		{
+			connDriver = new ConnDriver();
+			genericUtility = new E12GenericUtility();
+			conn = connDriver.getConnectDB("DriverITM");
+			conn.setAutoCommit(false);
+			connDriver = null;
+			simpleDateFormat  = new SimpleDateFormat(genericUtility.getApplDateTimeFormat());
+			currDate          = simpleDateFormat.format( Calendar.getInstance().getTime() );
+			currDate          = genericUtility.getValidDateTimeString( currDate, genericUtility.getApplDateTimeFormat(),genericUtility.getDBDateTimeFormat() ) ;
+
+			sql = "select SIGN_STATUS from OBJ_SIGN_TRANS "
+				+ "WHERE ltrim(rtrim(REF_SER)) = 'S-RET' AND ltrim(rtrim(REF_ID)) = ? AND ltrim(rtrim(ROLE_CODE__SIGN)) = ? "
+				+ "AND SIGN_STATUS = 'U'";
+				
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1, tranId);
+			pstmt.setString(2, roleCode);
+			rs = pstmt.executeQuery();
+			
+			if (rs.next()) 
+			{
+				signStatus = rs.getString("SIGN_STATUS");
+			}
+			System.out.println("signStatus = " + signStatus);
+
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+			
+			if("U".equalsIgnoreCase(signStatus)){
+				
+				sql = "select code from users where emp_code = ? ";
+				pstmt = conn.prepareStatement(sql);
+				pstmt.setString(1, empCodeAprv);
+				rs = pstmt.executeQuery();
+				
+				if (rs.next()) 
+				{
+					userCode = rs.getString("code");
+				}
+				userCode = userCode == null ? "" : userCode.trim();
+	
+				rs.close();
+				rs = null;
+				pstmt.close();
+				pstmt = null;
+				
+				sql = "UPDATE OBJ_SIGN_TRANS "
+						+ "SET SIGN_DATE = ?, USER_ID__SIGN = ?, SIGN_REMARKS = 'HR_SPAN is over', SIGN_STATUS = 'V', EMP_CODE = ? "
+						+ "WHERE ltrim(rtrim(REF_SER)) = 'S-RET' AND ltrim(rtrim(REF_ID)) = ? AND ltrim(rtrim(ROLE_CODE__SIGN)) = ? "
+						+ "AND SIGN_STATUS = 'U'";
+						
+				pstmt = conn.prepareStatement(sql);
+				pstmt.setTimestamp(1,java.sql.Timestamp.valueOf(currDate));
+				pstmt.setString(2, userCode);
+				pstmt.setString(3, empCodeAprv);
+				pstmt.setString(4, tranId);
+				pstmt.setString(5, roleCode);
+				
+				resultCnt += pstmt.executeUpdate();
+				pstmt.close();
+				pstmt = null;
+				System.out.println("Update Successfully:"+resultCnt);
+				
+				processInfo = processId.split(":");
+				sql = "UPDATE WF_PRC_STATUS "
+						+ "SET STATUS_DATE = ?, PROCESS_STATUS = 4, ERR_STATUS = '0', "
+						+ "STATUS_REMARKS='Escalated -> Completing :"+processId+" Invoked :"+processId+"' "
+						+ "WHERE ltrim(rtrim(REF_SER)) = 'S-RET' AND REF_ID = ? AND PROCESS_ID = ? AND INSTANCE_ID = ? AND ACTIVITY_ID = ? AND PROCESS_STATUS != 3";
+				
+				pstmt = conn.prepareStatement(sql);
+				pstmt.setTimestamp(1,java.sql.Timestamp.valueOf(currDate));
+				pstmt.setString(2, tranId);
+				pstmt.setString(3, processInfo[0]);
+				pstmt.setString(4, processInfo[1]);
+				pstmt.setString(5, activityId);
+				resultCnt += pstmt.executeUpdate();
+				pstmt.close();
+				pstmt = null;
+				System.out.println("Update Successfully:"+resultCnt);
+			} 
+			else 
+			{
+				retString = "N";
+			}
+		}
+		catch (Exception e) {
+			System.out.println("Exception: SalesReturnWF escalate method ..> " + e.getMessage());
+			isError = true;
+			throw new ITMException(e);
+		} finally {
+			if(rs !=null)
+			{
+				rs.close();rs=null;
+			}
+			if(pstmt != null)
+            {
+				pstmt.close();pstmt = null;
+            }
+			if (conn != null) {
+				try {
+					if (isError || !(resultCnt > 0)) {
+						conn.rollback();
+						retString = "N";
+						System.out.println("SalesReturnWF escalate: Connection Rollback");
+					} else {
+						conn.commit();
+						retString = "Y";
+						System.out.println("SalesReturnWF escalate: Connection Commit");
+					}
+					conn.close();
+					conn = null;
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		return retString;
+	}
+	
+	public String approverSignStatusUpdate(String tranId, String empCodeAprv, String xmlDataAll, String processId, String roleCode, String activityId, String signStatusFlag) throws ITMException, Exception {
+		System.out.println("Parameters ::: tranId["+tranId+"],empCodeAprv["+empCodeAprv+"],xmlDataAll["+xmlDataAll+"],processId["+processId+"],roleCode["+roleCode+"],signStatusFlag["+signStatusFlag+"]");
+		String retString = "",signRemarks = "",empName = "";
+		Boolean isError = false;
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		E12GenericUtility genericUtility = null;
+		SimpleDateFormat  simpleDateFormat = null;
+		String currDate = "";
+		String userCode = "",processInfo[] = null;
+		int resultCnt = 0;
+		Connection conn = null;
+		ConnDriver connDriver = null;
+		empCodeAprv = checkNull(empCodeAprv);
+		tranId = checkNull(tranId);
+		processId = checkNull(processId);
+		signStatusFlag = checkNull(signStatusFlag);
+		roleCode = checkNull(roleCode);
+		
+		try
+		{
+			connDriver = new ConnDriver();
+			genericUtility = new E12GenericUtility();
+			conn = connDriver.getConnectDB("DriverITM");
+			conn.setAutoCommit(false);
+			connDriver = null;
+			simpleDateFormat  = new SimpleDateFormat(genericUtility.getApplDateTimeFormat());
+			currDate          = simpleDateFormat.format( Calendar.getInstance().getTime() );
+			currDate          = genericUtility.getValidDateTimeString( currDate, genericUtility.getApplDateTimeFormat(),genericUtility.getDBDateTimeFormat() ) ;
+			System.out.println(" approverSignStatusUpdate :: currDate :: ["+currDate+"]");
+				
+			sql = "select u.code,e.emp_fname || ' ' || e.emp_lname as emp_name from users u inner join employee e on e.emp_code = u.emp_code where e.emp_code = ? ";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1, empCodeAprv);
+			rs = pstmt.executeQuery();
+			
+			if (rs.next()) 
+			{
+				userCode = checkNull(rs.getString("code"));
+				empName  = checkNull(rs.getString("emp_name"));
+			}
+
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+			
+			if("S".equalsIgnoreCase(signStatusFlag)){
+				signRemarks = "Transaction Approved by "+empName+".";
+			}
+			else if("R".equalsIgnoreCase(signStatusFlag)){
+				signRemarks = "Transaction Rejected by "+empName+".";
+			}
+			else{
+				signRemarks = "Transaction Approved by "+empName+".";
+			}
+			
+			sql = "UPDATE OBJ_SIGN_TRANS "
+					+ "SET SIGN_DATE = ?, USER_ID__SIGN = ?, SIGN_REMARKS = '"+signRemarks+"', SIGN_STATUS = 'V', EMP_CODE = ? "
+					+ "WHERE ltrim(rtrim(REF_SER)) = 'S-RET' AND ltrim(rtrim(REF_ID)) = ? AND ltrim(rtrim(ROLE_CODE__SIGN)) = ? "
+					+ "AND SIGN_STATUS = 'U'";
+					
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setTimestamp(1,java.sql.Timestamp.valueOf(currDate));
+			pstmt.setString(2, userCode);
+			pstmt.setString(3, empCodeAprv);
+			pstmt.setString(4, tranId);
+			pstmt.setString(5, roleCode);
+			
+			resultCnt += pstmt.executeUpdate();
+			pstmt.close();
+			pstmt = null;
+			System.out.println("Update Successfully:"+resultCnt);
+			
+			processInfo = processId.split(":");
+			sql = "UPDATE WF_PRC_STATUS SET STATUS_DATE = ?, PROCESS_STATUS = 4, ERR_STATUS = '0', STATUS_REMARKS = '"+signRemarks+"' " +
+				  "WHERE ltrim(rtrim(REF_SER)) = 'S-RET' AND REF_ID = ? AND PROCESS_ID = ? AND INSTANCE_ID = ? AND ACTIVITY_ID = ? AND PROCESS_STATUS != 3";
+			
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setTimestamp(1,java.sql.Timestamp.valueOf(currDate));
+			pstmt.setString(2, tranId);
+			pstmt.setString(3, processInfo[0]);
+			pstmt.setString(4, processInfo[1]);
+			pstmt.setString(5, activityId);
+			resultCnt += pstmt.executeUpdate();
+			pstmt.close();
+			pstmt = null;
+			System.out.println("Update Successfully:"+resultCnt);
+		}
+		catch (Exception e) {
+			System.out.println("Exception: approverSignStatusUpdate method ..> " + e.getMessage());
+			isError = true;
+			throw new ITMException(e);
+		} finally {
+			if(rs !=null)
+			{
+				rs.close();rs=null;
+			}
+			if(pstmt != null)
+            {
+				pstmt.close();pstmt = null;
+            }
+			if (conn != null) {
+				try {
+					if (isError || !(resultCnt > 0)) {
+						conn.rollback();
+						retString = "N";
+						System.out.println("approverSignStatusUpdate: Connection Rollback");
+					} else {
+						conn.commit();
+						retString = "Y";
+						System.out.println("approverSignStatusUpdate: Connection Commit");
+					}
+					conn.close();
+					conn = null;
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		return retString;
+	}
+	public String checkEscalationStatus(String tranId, String empCodeAprv, String xmlDataAll, String processId, String roleCode, String activityId) throws ITMException, Exception {
+		System.out.println("checkEscalationStatus Parameters ::: tranId["+tranId+"],empCodeAprv["+empCodeAprv+"],xmlDataAll["+xmlDataAll+"],processId["+processId+"]");
+		String retString = "";
+		Boolean isError = false;
+		PreparedStatement pstmt = null;
+		ResultSet rs = null;
+		String sql = "",prcId = "", instanceId = "",processInfo[] = null;
+		int escalationCnt = 0, finAprvObjTransCnt = 0;
+		Connection conn = null;
+		ConnDriver connDriver = null;
+		empCodeAprv = checkNull(empCodeAprv);
+		tranId = checkNull(tranId);
+		processId = checkNull(processId);
+		roleCode = checkNull(roleCode);
+		
+		try
+		{
+			connDriver     = new ConnDriver();
+			conn           = connDriver.getConnectDB("DriverITM");
+			conn.setAutoCommit(false);
+			connDriver     = null;
+			processInfo    = processId.split(":");
+			prcId          = checkNull(processInfo[0]);
+			instanceId     = checkNull(processInfo[1]);
+			System.out.println(" checkEscalationStatus :: prcId :: ["+prcId+"]"+" instanceId: "+instanceId);
+				
+			sql = "SELECT COUNT(DISTINCT(W.ACTIVITY_ID)) AS COUNT FROM OBJ_SIGN_TRANS O INNER JOIN WF_PRC_STATUS W " +
+				  "ON O.REF_ID = W.REF_ID WHERE O.SIGN_STATUS='V' AND W.PROCESS_STATUS = 4 AND O.REF_ID ='"+tranId+"' AND W.INSTANCE_ID  = "+instanceId+" ";
+			
+			pstmt = conn.prepareStatement(sql);
+			rs = pstmt.executeQuery();
+			
+			if (rs.next()) 
+			{
+				escalationCnt = rs.getInt("COUNT");
+			}
+
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+			
+			sql = "SELECT COUNT(W.ACTIVITY_ID) AS COUNT FROM WF_PRC_STATUS W WHERE W.ACTIVITY_ID = '"+activityId+"' AND W.REF_ID ='"+tranId+"' AND W.INSTANCE_ID  = "+instanceId+" ";
+		
+			pstmt = conn.prepareStatement(sql);
+			rs = pstmt.executeQuery();
+			
+			if (rs.next()) 
+			{
+				finAprvObjTransCnt = rs.getInt("COUNT");
+			}
+	
+			rs.close();
+			rs = null;
+			pstmt.close();
+			pstmt = null;
+			System.out.println("escalationCnt :"+escalationCnt+" finAprvObjTransCnt:"+finAprvObjTransCnt);
+			
+		}
+		catch (Exception e) {
+			System.out.println("Exception: checkEscalationStatus method ..> " + e.getMessage());
+			isError = true;
+			throw new ITMException(e);
+		} finally {
+			if(rs !=null)
+			{
+				rs.close();rs=null;
+			}
+			if(pstmt != null)
+            {
+				pstmt.close();pstmt = null;
+            }
+			if (conn != null) {
+				try {
+					if (isError || !(finAprvObjTransCnt < 1)) {
+						retString = "N";
+					} else {
+						retString = "Y";
+					}
+					conn.close();
+					conn = null;
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		return retString;
+	}
+	private String checkNull(String str) {
+		if(str == null){
+			str = "";
+		}
+		else{
+			str = str.trim();
+		}
+		return str;
+	}
+}

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

+package ibase.webitm.ejb.dis;
+
+import ibase.webitm.ejb.ActionHandlerEJB;
+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 java.sql.SQLException;
+
+import javax.ejb.Stateless;
+
+@Stateless
+public class SalesReturnWfEJB extends ActionHandlerEJB implements SalesReturnWfEJBLocal, SalesReturnWfEJBRemote {
+	public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException, ITMException {
+		System.out.println("@@@@@@@@@@@@@@@@@@@@ SalesReturnWfEJB @@@@@@@@@@@@@@@@");
+		String userId = "";
+		String errString = "";
+		ValidatorEJB validatorEJB = null;
+		ITMDBAccessEJB itmDBAccessEJB = null;
+		Connection conn = null;
+		PreparedStatement pStmt = null;
+		ResultSet rs = null;
+		String sql = "";
+		String status = "",confirmed = "",retString = "";
+		String[] authencate = new String[2];
+		authencate[0] = "";
+		authencate[1] = "";
+		boolean isError = false;
+		
+		try {
+			itmDBAccessEJB = new ITMDBAccessEJB();
+			validatorEJB = new ValidatorEJB();
+			conn = getConnection();
+			conn.setAutoCommit(false);
+			userId = validatorEJB.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
+
+			System.out.println("tran_id ..> " + tranId+" userId: "+userId+" xtraParams: "+xtraParams+" forcedFlag: "+forcedFlag);
+			tranId = checkNull(tranId);
+
+			sql = " SELECT wf_status,confirmed FROM sreturn WHERE tran_id = ? ";
+
+			pStmt = conn.prepareStatement(sql);
+			pStmt.setString(1, tranId);
+			rs = pStmt.executeQuery();
+			
+			if (rs.next()) {
+				status     = rs.getString("wf_status");
+				confirmed  = rs.getString("confirmed");
+			}
+			
+			status    = checkNull(status);
+			confirmed = checkNull(confirmed);
+			closePstmtRs(pStmt, rs);
+
+			if(!"Y".equalsIgnoreCase(confirmed)){
+				if ("O".equalsIgnoreCase(status) || "R".equalsIgnoreCase(status)) {
+						GenericWorkflowClass wfGenericClass = new GenericWorkflowClass();
+						retString = wfGenericClass.invokeWorkflow(conn, tranId, xtraParams, "w_salesreturn_retn", "salesreturn_retn");
+						if ("success".equalsIgnoreCase(retString)) {
+							
+							sql = "UPDATE SRETURN SET WF_STATUS = 'S' WHERE TRAN_ID = ? ";
+							pStmt = conn.prepareStatement(sql);
+							pStmt.setString(1, tranId);
+							int updCount = pStmt.executeUpdate();
+							
+							if (updCount > 0) {
+								errString = new ITMDBAccessEJB().getErrorString("", "VFMWRKFLWS", "");
+							}
+							else{
+								errString = new ITMDBAccessEJB().getErrorString("", "VFMWRKFLWF", "");
+	    						isError=true;
+							}
+						} else {
+							errString = new ITMDBAccessEJB().getErrorString("", "VFMWRKFLWF", "");
+						}
+				} 
+				else {
+					errString = new ITMDBAccessEJB().getErrorString("", "VTMWFALINT", "");
+				}
+			}
+			else{
+				errString = new ITMDBAccessEJB().getErrorString("", "VTMWFALCNF", "");
+			}
+		} catch (Exception e) {
+			isError = true;
+			System.out.println("Exception: confirm method ..> " + e.getMessage());
+			e.printStackTrace();
+			errString = itmDBAccessEJB.getErrorString("", "VFMWRKFLWF", userId);
+			throw new ITMException(e);
+		} finally {
+			if (conn != null) {
+				try {
+					if (isError) {
+						conn.rollback();
+						System.out.println("SalesReturnWfEJB: confirm: Connection Rollback");
+					} else {
+						conn.commit();
+						System.out.println("SalesReturnWfEJB: confirm: Connection Commit");
+					}
+					conn.close();
+					conn = null;
+				} catch (Exception e) {
+					e.printStackTrace();
+				}
+			}
+		}
+		return errString;
+	}
+
+
+	private String checkNull(String str) {
+		if(str == null){
+			str = "";
+		}
+		else{
+			str = str.trim();
+		}
+		return str;
+	}
+
+	private void closePstmtRs(PreparedStatement pStmt, ResultSet rs) {
+		if (pStmt != null) {
+			try {
+				pStmt.close();
+			} catch (SQLException localSQLException1) {
+			}
+			pStmt = null;
+		}
+		if (rs != null) {
+			try {
+				rs.close();
+			} catch (SQLException e) {
+				e.printStackTrace();
+			}
+			rs = null;
+		}
+	}
+}

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

+package ibase.webitm.ejb.dis;
+
+import ibase.webitm.ejb.ActionHandlerLocal;
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import javax.ejb.Local;
+
+@Local
+public interface SalesReturnWfEJBLocal extends ActionHandlerLocal {
+	public String confirm(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
+}

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

+package ibase.webitm.ejb.dis;
+
+import ibase.webitm.ejb.ActionHandlerRemote;
+import ibase.webitm.utility.ITMException;
+import java.rmi.RemoteException;
+import javax.ejb.Remote;
+
+@Remote
+public interface SalesReturnWfEJBRemote extends ActionHandlerRemote {
+	public String confirm(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
+}