Updated workflow components

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

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

+package ibase.webitm.ejb.dis.adv;
+
+import ibase.system.config.ConnDriver;
+import ibase.utility.UserInfoBean;
+import ibase.webitm.utility.ITMException;
+
+import java.rmi.RemoteException;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+
+public class ConsumpIssueConfWF 
+{
+	public String confirm(String consIssue, String empCodeAprv, String xmlDataAll, String processId, String keyFlag, String userInfoStr) throws RemoteException, ITMException
+	{
+		
+	    String retString = "";
+	    Connection conn = null;
+	    PreparedStatement pstmt = null;
+	    String sql = "";
+	    ConnDriver connDriver = new ConnDriver();
+
+	    int updcnt = 0;
+	    
+	    try {
+			System.out.println("Exception in Try block of ConsumpIssueConfWF.confirm()");
+			//conn = connDriver.getConnectDB("DriverITM");
+			System.out.println("Inside ConsumpIssueConfWF confirm section: "+userInfoStr);
+			UserInfoBean userInfo = new UserInfoBean(userInfoStr);
+	    	String transDB = userInfo.getTransDB();
+	    	System.out.println("get TransDB connetion in ConsumpIssueConfWF : "+transDB);
+		     if (transDB != null && transDB.trim().length() > 0)
+		           {
+		               conn = connDriver.getConnectDB(transDB);
+		           }
+			  conn.setAutoCommit(false);
+			  connDriver = null;
+	    	
+	    	empCodeAprv = empCodeAprv == null ? "" : empCodeAprv.trim();
+	    	
+	    	if ((xmlDataAll != null) && (xmlDataAll.trim().length() != 0)) 
+	    	{
+	    		sql = "update consume_iss set confirmed = 'Y', conf_date = sysdate where cons_order = ?";
+	    		pstmt = conn.prepareStatement(sql);
+
+	    		pstmt.setString(1, consIssue);
+	    		updcnt = pstmt.executeUpdate();
+		        pstmt.close();
+		        pstmt = null;
+		        System.out.println("Updated Successfully:" + updcnt);
+
+		        if (updcnt > 0) 
+		        {
+		          conn.commit();
+		          retString = "Y";
+		        }
+		        
+		        conn.rollback();
+		        retString = "N";
+		    }
+	    	
+		} 
+	    catch (Exception e) {
+	    	try
+		      {
+		        conn.rollback();
+		      }
+		      catch (SQLException e1)
+		      {
+		        e1.printStackTrace();
+		      }
+		      e.printStackTrace();
+		      System.out.println("Exception occurred in catch block of ConsumpIssueConfWF.confirm()");
+		      
+		      throw new ITMException(e);
+	    }
+	    finally
+	    {
+		      if (conn != null)
+		      {
+		        try
+		        {
+		          conn.close();
+		          conn = null;
+		        }
+		        catch (SQLException e)
+		        {
+		          e.printStackTrace();
+		          System.out.println("Exception occurred in finally block of ConsumpIssueConfWF.confirm()");
+		        }
+		      }
+		}
+		
+	    return retString;
+		
+	}
+}

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

+package ibase.webitm.ejb.dis.adv;
+
+import ibase.system.config.ConnDriver;
+import ibase.utility.UserInfoBean;
+import ibase.webitm.utility.ITMException;
+
+import java.rmi.RemoteException;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+
+public class PurContractConfWF 
+{
+	public String confirm(String contractNo, String empCodeAprv, String xmlDataAll, String processId, String keyFlag, String userInfoStr) throws RemoteException, ITMException
+	{
+		
+	    String retString = "";
+	    Connection conn = null;
+	    PreparedStatement pstmt = null;
+	    String sql = "";
+	    ConnDriver connDriver = new ConnDriver();
+
+	    int updcnt = 0;
+	    
+	    try {
+			System.out.println("Exception in Try block of PurContractConfWF.confirm()");
+			//conn = connDriver.getConnectDB("DriverITM");
+			System.out.println("Inside PurContractConfWF confirm section: "+userInfoStr);
+			UserInfoBean userInfo = new UserInfoBean(userInfoStr);
+	    	String transDB = userInfo.getTransDB();
+	    	System.out.println("get TransDB connetion in PurContractConfWF : "+transDB);
+		     if (transDB != null && transDB.trim().length() > 0)
+		           {
+		               conn = connDriver.getConnectDB(transDB);
+		           }
+			conn.setAutoCommit(false);
+			connDriver = null;
+	    	
+	    	
+	    	empCodeAprv = empCodeAprv == null ? "" : empCodeAprv.trim();
+	    	
+	    	if ((xmlDataAll != null) && (xmlDataAll.trim().length() != 0)) 
+	    	{
+	    		sql = "update pcontract_hdr set confirmed = 'Y' where contract_no = ?";
+	    		pstmt = conn.prepareStatement(sql);
+
+	    		pstmt.setString(1, contractNo);
+	    		updcnt = pstmt.executeUpdate();
+		        pstmt.close();
+		        pstmt = null;
+		        System.out.println("Updated Successfully:" + updcnt);
+
+		        if (updcnt > 0) 
+		        {
+		          conn.commit();
+		          retString = "Y";
+		        }
+		        
+		        conn.rollback();
+		        retString = "N";
+		    }
+	    	
+		} 
+	    catch (Exception e) {
+	    	try
+		      {
+		        conn.rollback();
+		      }
+		      catch (SQLException e1)
+		      {
+		        e1.printStackTrace();
+		      }
+		      e.printStackTrace();
+		      System.out.println("Exception occurred in catch block of PurContractConfWF.confirm()");
+		      
+		      throw new ITMException(e);
+	    }
+	    finally
+	    {
+		      if (conn != null)
+		      {
+		        try
+		        {
+		          conn.close();
+		          conn = null;
+		        }
+		        catch (SQLException e)
+		        {
+		          e.printStackTrace();
+		          System.out.println("Exception occurred in finally block of PurContractConfWF.confirm()");
+		        }
+		      }
+		}
+		
+	    return retString;
+		
+	}
+}

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

+package ibase.webitm.ejb.dis.adv;
+
+import ibase.system.config.ConnDriver;
+import ibase.utility.UserInfoBean;
+import ibase.webitm.utility.ITMException;
+
+import java.rmi.RemoteException;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.SQLException;
+
+public class SalesContractConfWF 
+{
+	public String confirm(String contractNo, String empCodeCon, String xmlDataAll, String processId, String keyFlag, String userInfoStr) throws RemoteException, ITMException
+	{
+		
+	    String retString = "";
+	    Connection conn = null;
+	    PreparedStatement pstmt = null;
+	    String sql = "";
+	    ConnDriver connDriver = new ConnDriver();
+
+	    int updcnt = 0;
+	    
+	    try {
+	    	
+	    	System.out.println("Inside Sales contracted confirm()");
+	    	//conn = connDriver.getConnectDB("DriverITM");
+	    	System.out.println("Inside SalesContractConfWF confirm section: "+userInfoStr);
+			UserInfoBean userInfo = new UserInfoBean(userInfoStr);
+	    	String transDB = userInfo.getTransDB();
+	    	System.out.println("get TransDB connetion in SalesContractConfWF : "+transDB);
+		     if (transDB != null && transDB.trim().length() > 0)
+		           {
+		               conn = connDriver.getConnectDB(transDB);
+		           }
+			conn.setAutoCommit(false);
+			connDriver = null;
+	    	
+	    	empCodeCon = empCodeCon == null ? "" : empCodeCon.trim();
+	    	
+	    	if ((xmlDataAll != null) && (xmlDataAll.trim().length() != 0)) 
+	    	{
+	    		sql = "update scontract set confirmed = 'Y', conf_date = sysdate where contract_no = ?";
+	    		pstmt = conn.prepareStatement(sql);
+
+	    		pstmt.setString(1, contractNo);
+	    		updcnt = pstmt.executeUpdate();
+		        pstmt.close();
+		        pstmt = null;
+		        System.out.println("Updated Successfully:" + updcnt);
+
+		        if (updcnt > 0) 
+		        {
+		          conn.commit();
+		          retString = "Y";
+		        }
+		        
+		        conn.rollback();
+		        retString = "N";
+		    }
+	    	
+		} 
+	    catch (Exception e) {
+	    	try
+		      {
+		        conn.rollback();
+		      }
+		      catch (SQLException e1)
+		      {
+		        e1.printStackTrace();
+		      }
+		      e.printStackTrace();
+		      System.out.println("Exception occurred in catch block of SalesContractConfWF.confirm()");
+		      
+		      throw new ITMException(e);
+	    }
+	    finally
+	    {
+		      if (conn != null)
+		      {
+		        try
+		        {
+		          conn.close();
+		          conn = null;
+		        }
+		        catch (SQLException e)
+		        {
+		          e.printStackTrace();
+		          System.out.println("Exception occurred in finally block of SalesContractConfWF.confirm()");
+		        }
+		      }
+		}
+		
+	    return retString;
+		
+	}
+}

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

@@ -17,6 +17,6 @@ import javax.ejb.Local; // added for ejb3
 @Local // added for ejb3
 public interface SorderConfLocal extends ActionHandlerLocal
 {
-   public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
+   public String confirm(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException;
 
 }

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

@@ -15,5 +15,5 @@ import javax.ejb.Remote; // added for ejb3
 @Remote // added for ejb3
 public interface SorderConfRemote extends ActionHandlerRemote
 {
-		public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
+		public String confirm(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException;
 }

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

@@ -7,6 +7,7 @@
 
 package ibase.webitm.ejb.dis.adv;
 
+import ibase.utility.UserInfoBean;
 import ibase.webitm.utility.ITMException;
 import java.rmi.RemoteException;
 import ibase.webitm.ejb.dis.adv.SorderConf;
@@ -16,14 +17,17 @@ import javax.ejb.Stateless;
 @Stateless
 public class SorderConfWF implements SorderConfWFRemote, SorderConfWFLocal {
 
-	public String confirm(String saleOrder, String xtraParams, String forcedFlag) throws RemoteException, ITMException {
+	public String confirm(String saleOrder, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException, ITMException {
 		System.out.println("SOrderConfWF confirm method called>>>>>>>>>>>>>>>>>>>");
 		String retString = "N", errString = "";
 		SorderConf sorderConf = null;
 		
 		try {
+			UserInfoBean userInfo = new UserInfoBean(userInfoStr);
 			sorderConf = new SorderConf();
+			sorderConf.setUserInfo(userInfo);
 			errString = sorderConf.confirm(saleOrder, xtraParams, forcedFlag);
+			
 			if(errString != null && errString.trim().length() > 0)
 			{
 				if(errString.indexOf("VTCNFSUCC") > -1)