Commit dc7757ad authored by asonawane's avatar asonawane

changes to get the xtraparam values through workflow


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@92485 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 836583b4
...@@ -5,6 +5,7 @@ import ibase.utility.CommonConstants; ...@@ -5,6 +5,7 @@ import ibase.utility.CommonConstants;
import ibase.utility.GenericUtility; import ibase.utility.GenericUtility;
import ibase.webitm.ejb.ActionHandlerEJB; import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import ibase.wrkflw.utility.WorkflowLogger;
import java.io.ByteArrayInputStream; import java.io.ByteArrayInputStream;
import java.io.OutputStreamWriter; import java.io.OutputStreamWriter;
...@@ -12,6 +13,7 @@ import java.rmi.RemoteException; ...@@ -12,6 +13,7 @@ import java.rmi.RemoteException;
import java.sql.Connection; import java.sql.Connection;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.ResultSet; import java.sql.ResultSet;
import java.sql.SQLException;
import javax.ejb.Stateless; import javax.ejb.Stateless;
import javax.xml.parsers.DocumentBuilder; import javax.xml.parsers.DocumentBuilder;
...@@ -28,6 +30,8 @@ import org.w3c.dom.NodeList; ...@@ -28,6 +30,8 @@ import org.w3c.dom.NodeList;
@Stateless @Stateless
public class CallConfirmService extends ActionHandlerEJB implements CallConfirmServiceLocal,CallConfirmServiceRemote { public class CallConfirmService extends ActionHandlerEJB implements CallConfirmServiceLocal,CallConfirmServiceRemote {
final String XTRA_PARAMS_SEPARATOR = "~~";
@Override @Override
public String confirm(String objName, String tranID, String xtraParams, String forcedFlag) throws RemoteException, ITMException public String confirm(String objName, String tranID, String xtraParams, String forcedFlag) throws RemoteException, ITMException
{ {
...@@ -46,17 +50,18 @@ public class CallConfirmService extends ActionHandlerEJB implements CallConfirmS ...@@ -46,17 +50,18 @@ public class CallConfirmService extends ActionHandlerEJB implements CallConfirmS
return retString; return retString;
} }
public String confirmRecord(String businessObj,String tranID ,Connection conn, String xtraParams, String forcedFlag) throws ITMException public String confirmRecord(String businessObj,String tranID ,Connection conn, String refSer, String forcedFlag) throws ITMException
{ {
String methodName = "gbf_post"; String methodName = "gbf_post";
String actionURI="",sql="",serviceCode="",compName="",serviceURI="",retString=""; String actionURI="",sql="",serviceCode="",compName="",serviceURI="",retString="";
PreparedStatement pStmtSysEvent =null ,pStmtSysEvService=null ; PreparedStatement pStmtSysEvent =null ,pStmtSysEvService=null ;
ResultSet rsSysEvent,rsSysEvService; ResultSet rsSysEvent,rsSysEvService;
String xtraParams ="";
try{ try{
ConnDriver connDriver = new ConnDriver(); ConnDriver connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM"); conn = connDriver.getConnectDB("DriverITM");
GenericUtility genericUtility = GenericUtility.getInstance(); GenericUtility genericUtility = GenericUtility.getInstance();
xtraParams = getExtraParams(tranID,refSer,conn);
actionURI = "http://NvoServiceurl.org/" + methodName; actionURI = "http://NvoServiceurl.org/" + methodName;
sql = "SELECT SERVICE_CODE,COMP_NAME FROM SYSTEM_EVENTS WHERE OBJ_NAME = ? AND EVENT_CODE = 'pre_confirm' "; sql = "SELECT SERVICE_CODE,COMP_NAME FROM SYSTEM_EVENTS WHERE OBJ_NAME = ? AND EVENT_CODE = 'pre_confirm' ";
...@@ -215,4 +220,58 @@ public class CallConfirmService extends ActionHandlerEJB implements CallConfirmS ...@@ -215,4 +220,58 @@ public class CallConfirmService extends ActionHandlerEJB implements CallConfirmS
} }
private String getExtraParams(String tranID,String refSer,Connection conn) throws ITMException
{
String xtraParam="";
PreparedStatement pstmtExtraParm = null;
ResultSet rsExtraParm=null;
try{
String sqlExtraParm= "SELECT EMP_CODE ,USER_ID__SIGN FROM OBJ_SIGN_TRANS WHERE REF_ID =? AND REF_SER = ? ORDER BY LINE_NO DESC";
pstmtExtraParm = conn.prepareStatement(sqlExtraParm);
pstmtExtraParm.setString(1, tranID);
pstmtExtraParm.setString(2, refSer);
rsExtraParm = pstmtExtraParm.executeQuery();
if(rsExtraParm.next())
{
xtraParam = "loginCode=" + rsExtraParm.getString("USER_ID__SIGN") + XTRA_PARAMS_SEPARATOR + "loginEmpCode=" + rsExtraParm.getString("EMP_CODE") + XTRA_PARAMS_SEPARATOR + "runMode=I";
}
pstmtExtraParm.close();
pstmtExtraParm = null;
rsExtraParm.close();
rsExtraParm = null;
}
catch(Exception e)
{
throw new ITMException(e);
}
finally
{
if(pstmtExtraParm != null)
{
try {
pstmtExtraParm.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
pstmtExtraParm = null;
}
if(rsExtraParm != null)
{
try {
rsExtraParm.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
rsExtraParm = null;
}
}
return xtraParam;
}
} }
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