PB component called to generate Purchase voucher

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

webitm-fin/ibase/webitm/ejb/fin/PorcpVouchCreateSch.java

@@ -232,13 +232,15 @@ public class PorcpVouchCreateSch implements Schedule
 				     if(isValidReceipt)
 				     {
 				    	 
-						CreatePoRcpVoucher createVouc = new CreatePoRcpVoucher();
-						retString = createVouc.createPoRcpVoucher(tranidRcp,xtraParams, conn);
+						//CreatePoRcpVoucher createVouc = new CreatePoRcpVoucher();
+				    	 
+						//retString = createVouc.createPoRcpVoucher(tranidRcp,xtraParams, conn);
 						//fos1.write(("Status is::  [" + retString +"]\r\n").getBytes());
+				    	 retString=createVoucher("porcp",tranidRcp,xtraParams,conn);
 						System.out.println("retString----"+retString);
-						if( retString.indexOf("Success") != -1 )
+						if( retString.indexOf("PRCSTATUS") != -1 )
 						{
-							voucherId=retString.substring( retString.indexOf("<TranID>")+8, retString.indexOf("</TranID>"));
+							//voucherId=retString.substring( retString.indexOf("<TranID>")+8, retString.indexOf("</TranID>"));
 							conn.commit();
 						}
 						else
@@ -267,7 +269,8 @@ public class PorcpVouchCreateSch implements Schedule
 							*/
 							//strToWrite =strToWrite+ "TranID of Receipt : "+tranidRcp+"   Voucher No : "+voucherId+"\r\n\r\n";
 						strWrite="TranID of Receipt : "+tranidRcp+"   Voucher No : "+voucherId+"\n Return String : "+retString+"\r\n\r\n";
-							fos1.write(strWrite.getBytes());
+							//fos1.write(strWrite.getBytes());
+						fos1.write(retString.getBytes());
 							strWrite="";	
 						endDate = new java.util.Date(System.currentTimeMillis());
 						calendar.setTime(new java.sql.Timestamp(System.currentTimeMillis()));
@@ -381,6 +384,111 @@ public class PorcpVouchCreateSch implements Schedule
 		return log;
 	}
 	
+	public String createVoucher(String businessObj, String tranidRcp,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;
+		//System.out.println("confirmJournalVoucher(String businessObj, String tranIdFr,String xtraParams, String forcedFlag, Connection conn) called >>><!@#>");
+
+		try
+		{
+			//ConnDriver connDriver = new ConnDriver();
+			//conn = connDriver.getConnectDB("DriverITM");
+
+			methodName = "gbf_post";
+			actionURI = "http://NvoServiceurl.org/" + methodName;
+
+			sql = "SELECT SERVICE_CODE,COMP_NAME FROM SYSTEM_EVENTS WHERE OBJ_NAME = ? AND EVENT_CODE = 'create_voucher' ";
+			pstmt = conn.prepareStatement(sql);
+			pstmt.setString(1,businessObj);
+			rs = pstmt.executeQuery();
+			if ( rs.next() )
+			{
+				serviceCode = rs.getString("SERVICE_CODE");
+				compName = rs.getString("COMP_NAME");
+			}
+			System.out.println("serviceCode = "+serviceCode+" compName "+compName);
+			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");
+			}
+			System.out.println("serviceURI = "+serviceURI+" compName = "+compName);
+			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", "tran_id"), XMLType.XSD_STRING, ParameterMode.IN);
+			call.addParameter( new javax.xml.namespace.QName("http://NvoServiceurl.org", "XTRA_PARAMS"), XMLType.XSD_STRING, ParameterMode.IN);
+			call.addParameter( new javax.xml.namespace.QName("http://NvoServiceurl.org", "FORCED_FLAG"), XMLType.XSD_STRING, ParameterMode.IN);
+
+			aobj[0] = new String(compName);
+			aobj[1] = new String(tranidRcp);
+			aobj[2] = new String(xtraParams);
+			aobj[3] = new String("");
+			
+			//System.out.println("@@@@@@@@@@loginEmpCode:" +genericUtility.getValueFromXTRA_PARAMS(xtraParams,"loginEmpCode")+":");
+			System.out.println("@@@@@@ call.setReturnType(XMLType.XSD_STRING) executed........");
+			call.setReturnType(XMLType.XSD_STRING);
+
+			retString = (String)call.invoke(aobj);
+
+			System.out.println("Confirm Complete @@@@@@@@@@@ Return string from NVO is:==>["+retString+"]");
+
+		}
+		catch(Exception e)
+		{
+			e.printStackTrace();
+			throw new ITMException(e);
+		}
+		finally
+		{		
+			try{
+
+
+				if (pstmt != null )
+				{
+					pstmt.close();
+					pstmt = null;
+				}
+				/*if( conn != null ){
+					conn.close();
+					conn = null;
+				}*/
+			}
+			catch(Exception e)
+			{
+				System.out.println("Exception inCalling confirmed");
+				e.printStackTrace();
+				try{
+					conn.rollback();
+
+				}catch (Exception s)
+				{
+					System.out.println("Unable to rollback");
+					s.printStackTrace();
+				}
+				throw new ITMException(e);
+			}
+
+		}
+		return retString;
+	}