Skip to content

B
business-java
Commit 040ccc33 authored by jshaikh's avatar jshaikh
Browse files
Options 

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@181278 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 6c946759
Show whitespace changes
Inline Side-by-side
Showing with 4121 additions and 3423 deletions
webitm-dis/ibase/webitm/ejb/dis/adv/PurContractConfWF.java → webitm-dis/ibase/webitm/ejb/dis/adv/PContractConfWF.java
View file @ 040ccc33
......@@ -2,33 +2,41 @@ package ibase.webitm.ejb.dis.adv;
import ibase.system.config.ConnDriver;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.ITMDBAccessEJB;
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;
public class PurContractConfWF
public class PContractConfWF
{
public String confirm(String contractNo, String empCodeAprv, String xmlDataAll, String processId, String keyFlag, String userInfoStr) throws RemoteException, ITMException
{
String retString = "";
String errString = "";
Connection conn = null;
ITMDBAccessEJB itmDBAccessEJB = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
String status = "", confirmed = "", wf_status = "", line_no = "";
String sql = "";
String loginCode = "", loginSiteCode = "";
ConnDriver connDriver = new ConnDriver();
java.sql.Date currentDate = new java.sql.Date(new java.util.Date().getTime());
int updcnt = 0;
try {
System.out.println("Inside Try block of PurContractConfWF.confirm()");
System.out.println("Exception in Try block of PContractConfWF.confirm()");
//conn = connDriver.getConnectDB("DriverITM");
System.out.println("Inside PurContractConfWF confirm section: "+userInfoStr);
System.out.println("Inside PContractConfWF confirm section: "+userInfoStr);
UserInfoBean userInfo = new UserInfoBean(userInfoStr);
String transDB = userInfo.getTransDB();
System.out.println("get TransDB connection in PurContractConfWF : "+transDB);
System.out.println("get TransDB connection in PContractConfWF : "+transDB);
if (transDB != null && transDB.trim().length() > 0)
{
conn = connDriver.getConnectDB(transDB);
......@@ -37,18 +45,74 @@ public class PurContractConfWF
{
conn = connDriver.getConnectDB("DriverITM");
}
conn.setAutoCommit(false);
connDriver = null;
conn.setAutoCommit(false);
empCodeAprv = empCodeAprv == null ? "" : empCodeAprv.trim();
if ((xmlDataAll != null) && (xmlDataAll.trim().length() != 0))
{
sql = "update pcontract_hdr set confirmed = 'Y' where contract_no = ?";
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"));
}
closePstmtRs(pstmt, rs);
sql = " SELECT status,confirmed,wf_status FROM pcontract_hdr WHERE contract_no = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, contractNo);
rs = pstmt.executeQuery();
if (rs.next()) {
status = checkNull(rs.getString("status"));
confirmed = checkNull(rs.getString("confirmed"));
wf_status = checkNull(rs.getString("wf_status"));
}
closePstmtRs(pstmt, rs);
/*sql = "select max(line_no) from obj_sign_trans where ref_ser = 'P-CON' and ref_id = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, contractNo);
rs = pstmt.executeQuery();
if (rs.next()) {
line_no = checkNull(rs.getString("line_no"));
}
closePstmtRs(pstmt, rs);*/
if("Y".equalsIgnoreCase(confirmed))
{
errString = new ITMDBAccessEJB().getErrorString("", "VTMWFALCNF", "");
return errString;
}
else if("X".equalsIgnoreCase(status) || "C".equalsIgnoreCase(status))
{
errString = new ITMDBAccessEJB().getErrorString("", "VTWFCLOCAN", "");
return errString;
}
else
{
if((xmlDataAll != null) && (xmlDataAll.trim().length() != 0))
{
sql = "update pcontract_hdr set confirmed = 'Y', status_date = ?, status = 'O' where contract_no = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setDate(1, currentDate);
pstmt.setString(2, contractNo);
updcnt = pstmt.executeUpdate();
pstmt.close();
pstmt = null;
......@@ -65,6 +129,7 @@ public class PurContractConfWF
retString = "N";
}
}
}
}
catch (Exception e) {
......@@ -97,8 +162,40 @@ public class PurContractConfWF
}
}
}
System.out.println("Return string from PContractConfWF confirm method is: "+retString);
return retString;
}
private String checkNull(String str)
{
if(str == null){
str = "";
}
else{
str = str.trim();
}
return str;
}
private void closePstmtRs(PreparedStatement pStmt, ResultSet rs)
{
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
rs = null;
}
if (pStmt != null) {
try {
pStmt.close();
} catch (SQLException localSQLException1) {
}
pStmt = null;
}
}
}
webitm-dis/ibase/webitm/ejb/dis/adv/PContractConfWfEJB.java
View file @ 040ccc33
package ibase.webitm.ejb.dis.adv;
import ibase.system.config.ConnDriver;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ValidatorEJB;
......@@ -18,10 +19,29 @@ import javax.ejb.Stateless;
@Stateless
public class PContractConfWfEJB extends ActionHandlerEJB implements PContractConfWfEJBLocal, PContractConfWfEJBRemote
{
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException, ITMException {
System.out.println("@@@@@@@@@@@@@@@@@@@@ PContractConfWfEJB @@@@@@@@@@@@@@@@");
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException, ITMException
{
String userInfoStr = "";
String errString = "";
try
{
userInfoStr = confirm(tranId, xtraParams, forcedFlag, userInfoStr);
System.out.println("userInfoStr of confirm::::: " +userInfoStr);
}
catch(Exception e)
{
System.out.println("Exception in [PContractConfWfEJB] confirm " + e.getMessage());
throw new ITMException(e);
}
return errString;
}
public String confirm(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException, ITMException
{
System.out.println("@@@@@@@@@@@@@@@@@@@@ PContractConfWfEJB : confirm @@@@@@@@@@@@@@@@");
String userId = "";
String errString = "";
String transDB = "";
ValidatorEJB validatorEJB = null;
ITMDBAccessEJB itmDBAccessEJB = null;
Connection conn = null;
......@@ -29,7 +49,7 @@ public class PContractConfWfEJB extends ActionHandlerEJB implements PContractCon
PreparedStatement pStmt = null;
ResultSet rs = null;
String sql = "";
String status = "",confirmed = "",retString = "";
String status = "",confirmed = "",retString = "",wf_status = "";
String[] authencate = new String[2];
authencate[0] = "";
authencate[1] = "";
......@@ -38,14 +58,30 @@ public class PContractConfWfEJB extends ActionHandlerEJB implements PContractCon
try {
itmDBAccessEJB = new ITMDBAccessEJB();
validatorEJB = new ValidatorEJB();
conn = getConnection();
//conn = getConnection();
if(userInfoStr != null && userInfoStr.trim().length() > 0)
{
UserInfoBean userInfo = new UserInfoBean(userInfoStr);
transDB = userInfo.getTransDB();
}
if (transDB != null && transDB.trim().length() > 0)
{
conn = connDriver.getConnectDB(transDB);
}
else
{
conn = connDriver.getConnectDB("DriverITM");
}
//connDriver = null;
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 status,confirmed FROM pcontract_hdr WHERE contract_no = ? ";
sql = " SELECT status,confirmed,wf_status FROM pcontract_hdr WHERE contract_no = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, tranId);
......@@ -54,24 +90,34 @@ public class PContractConfWfEJB extends ActionHandlerEJB implements PContractCon
if (rs.next()) {
status = rs.getString("status");
confirmed = rs.getString("confirmed");
wf_status = rs.getString("wf_status");
}
status = checkNull(status);
confirmed = checkNull(confirmed);
wf_status = checkNull(wf_status);
closePstmtRs(pStmt, rs);
if(!"Y".equalsIgnoreCase(confirmed) || "".equalsIgnoreCase(confirmed))
if(!"Y".equalsIgnoreCase(confirmed))
{
if ("O".equalsIgnoreCase(status) || "R".equalsIgnoreCase(status) || "".equalsIgnoreCase(status))
if("X".equalsIgnoreCase(status) || "C".equalsIgnoreCase(status))
{
errString = new ITMDBAccessEJB().getErrorString("", "VTWFCLOCAN", "");
}
else if ("O".equalsIgnoreCase(status) || "".equalsIgnoreCase(status))
{
if("O".equalsIgnoreCase(wf_status) || "R".equalsIgnoreCase(wf_status) || "".equalsIgnoreCase(wf_status))
{
GenericWorkflowClass wfGenericClass = new GenericWorkflowClass();
retString = wfGenericClass.invokeWorkflow(conn, tranId, xtraParams, "w_pcontract", "pcontract");
if ("success".equalsIgnoreCase(retString)) {
sql = "UPDATE PCONTRACT_HDR SET status = 'S' WHERE CONTRACT_NO = ? ";
sql = "UPDATE PCONTRACT_HDR SET wf_status = 'S' WHERE CONTRACT_NO = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, tranId);
int updCount = pStmt.executeUpdate();
closePstmtRs(pStmt, rs);
if (updCount > 0) {
errString = new ITMDBAccessEJB().getErrorString("", "VFMWRKFLWS", "");
......@@ -84,10 +130,15 @@ public class PContractConfWfEJB extends ActionHandlerEJB implements PContractCon
errString = new ITMDBAccessEJB().getErrorString("", "VFMWRKFLWF", "");
}
}
else {
else
{
errString = new ITMDBAccessEJB().getErrorString("", "VTMWFALINT", "");
}
}
else {
errString = new ITMDBAccessEJB().getErrorString("", "VFMWRKFLWF", "");
}
}
else{
errString = new ITMDBAccessEJB().getErrorString("", "VTMWFALCNF", "");
}
......@@ -118,7 +169,164 @@ public class PContractConfWfEJB extends ActionHandlerEJB implements PContractCon
}
private String checkNull(String str) {
public String rejection(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String userInfoStr = "";
String errString = "";
try
{
userInfoStr = rejection(tranId, xtraParams, forcedFlag, userInfoStr);
System.out.println("userInfoStr of rejection::::: " +userInfoStr);
}
catch(Exception e)
{
System.out.println("Exception in [PContractConfWfEJB] rejection " + e.getMessage());
throw new ITMException(e);
}
return errString;
}
public String rejection(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException
{
System.out.println("================ PContractConfWfEJB : rejection ================");
String userId = "";
String errString = "";
ValidatorEJB validatorEJB = null;
ITMDBAccessEJB itmDBAccessEJB = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
PreparedStatement pStmt = null;
ResultSet rs = null;
String sql = "";
String transDB = "";
String status = "",confirmed = "",retString = "", wf_status = "";
String[] authencate = new String[2];
authencate[0] = "";
authencate[1] = "";
boolean isError = false;
try {
itmDBAccessEJB = new ITMDBAccessEJB();
validatorEJB = new ValidatorEJB();
//conn = getConnection();
if(userInfoStr != null && userInfoStr.trim().length() > 0)
{
UserInfoBean userInfo = new UserInfoBean(userInfoStr);
transDB = userInfo.getTransDB();
}
if (transDB != null && transDB.trim().length() > 0)
{
conn = connDriver.getConnectDB(transDB);
}
else
{
conn = connDriver.getConnectDB("DriverITM");
}
//connDriver = null;
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 status,confirmed,wf_status FROM pcontract_hdr WHERE contract_no = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, tranId);
rs = pStmt.executeQuery();
if (rs.next())
{
confirmed = rs.getString("confirmed");
status = rs.getString("status");
wf_status = rs.getString("wf_status");
}
confirmed = checkNull(confirmed);
status = checkNull(status);
wf_status = checkNull(wf_status);
closePstmtRs(pStmt, rs);
if(!"Y".equalsIgnoreCase(confirmed))
{
/*if("X".equalsIgnoreCase(status) || "C".equalsIgnoreCase(status))
{
errString = new ITMDBAccessEJB().getErrorString("", "VTWFCLOCAN", "");
}*/
if ("O".equalsIgnoreCase(wf_status) || "R".equalsIgnoreCase(wf_status) || "S".equalsIgnoreCase(wf_status) || "".equalsIgnoreCase(wf_status))
{
sql = "UPDATE PCONTRACT_HDR SET WF_STATUS = 'O' WHERE CONTRACT_NO = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, tranId);
int updCount = pStmt.executeUpdate();
closePstmtRs(pStmt, rs);
if (updCount > 0)
{
retString="Y";
errString = new ITMDBAccessEJB().getErrorString("", "VFMWFOPN", "");
}
else
{
errString = new ITMDBAccessEJB().getErrorString("", "VFMWFFAIL", "");
isError=true;
}
}
else
{
errString = new ITMDBAccessEJB().getErrorString("", "VTMWFALINT", "");
}
}
else
{
errString = new ITMDBAccessEJB().getErrorString("", "VFMWFCONFN", "");
}
}
catch (Exception e)
{
isError = true;
System.out.println("Exception: rejection 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("PContractConfWfEJB: rejection: Connection Rollback");
}
else
{
conn.commit();
System.out.println("PContractConfWfEJB: rejection: Connection Commit");
}
conn.close();
conn = null;
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
return retString;
}
private String checkNull(String str)
{
if(str == null){
str = "";
}
......@@ -128,14 +336,8 @@ public class PContractConfWfEJB extends ActionHandlerEJB implements PContractCon
return str;
}
private void closePstmtRs(PreparedStatement pStmt, ResultSet rs) {
if (pStmt != null) {
try {
pStmt.close();
} catch (SQLException localSQLException1) {
}
pStmt = null;
}
private void closePstmtRs(PreparedStatement pStmt, ResultSet rs)
{
if (rs != null) {
try {
rs.close();
......@@ -144,5 +346,14 @@ public class PContractConfWfEJB extends ActionHandlerEJB implements PContractCon
}
rs = null;
}
if (pStmt != null) {
try {
pStmt.close();
} catch (SQLException localSQLException1) {
}
pStmt = null;
}
}
}
webitm-dis/ibase/webitm/ejb/dis/adv/PContractConfWfEJBLocal.java
View file @ 040ccc33
package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import javax.ejb.Local;
......@@ -11,4 +12,7 @@ import ibase.webitm.utility.ITMException;
public interface PContractConfWfEJBLocal extends ActionHandlerLocal
{
public String confirm(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
public String confirm(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException;
public String rejection(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
public String rejection(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException;
}
webitm-dis/ibase/webitm/ejb/dis/adv/PContractConfWfEJBRemote.java
View file @ 040ccc33
package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
import java.sql.Connection;
import javax.ejb.Remote;
......@@ -10,5 +11,8 @@ import ibase.webitm.utility.ITMException;
@Remote
public interface PContractConfWfEJBRemote extends ActionHandlerRemote
{
public String confirm(String paramString1, String paramString2, String paramString3) throws RemoteException, ITMException;
public String confirm(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
public String confirm(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException;
public String rejection(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
public String rejection(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException;
}
webitm-dis/ibase/webitm/ejb/dis/adv/PorderConf.java
View file @ 040ccc33
This source diff could not be displayed because it is too large. You can view the blob instead.
webitm-dis/ibase/webitm/ejb/dis/adv/PorderConfWF.java
View file @ 040ccc33
......@@ -9,14 +9,16 @@ 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.PorderConf;
import javax.ejb.Stateless;
@Stateless
public class PorderConfWF implements PorderConfWFRemote, PorderConfWFLocal {
public String confirm(String purcOrder, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException, ITMException {
public String confirm(String purcOrder, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException, ITMException
{
System.out.println("PorderConfWF confirm method called>>>>>>>>>>>>>>>>>>>");
String retString = "N", errString = "";
PorderConf porderConf = null;
......@@ -46,4 +48,6 @@ public class PorderConfWF implements PorderConfWFRemote, PorderConfWFLocal {
System.out.println("returnString>>>> "+retString);
return retString;
}
}
webitm-dis/ibase/webitm/ejb/dis/adv/PorderConfWFRemote.java
View file @ 040ccc33
......@@ -7,4 +7,5 @@ import javax.ejb.Remote;
@Remote
public interface PorderConfWFRemote {
public String confirm(String purcOrder, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException, ITMException;
}
webitm-dis/ibase/webitm/ejb/dis/adv/PorderConfWfEJB.java 0 → 100644
View file @ 040ccc33
package ibase.webitm.ejb.dis.adv;
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 ibase.system.config.ConnDriver;
import ibase.utility.UserInfoBean;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ValidatorEJB;
import ibase.webitm.ejb.dis.GenericWorkflowClass;
import ibase.webitm.utility.ITMException;
@Stateless
public class PorderConfWfEJB extends ActionHandlerEJB implements PorderConfWfEJBLocal, PorderConfWfEJBRemote
{
public String confirm(String pOrder, String xtraParams, String forcedFlag) throws RemoteException, ITMException
{
String userInfoStr = "";
String errString = "";
try
{
userInfoStr = confirm(pOrder, xtraParams, forcedFlag, userInfoStr);
System.out.println("userInfoStr of confirm::::: " +userInfoStr);
}
catch(Exception e)
{
System.out.println("Exception in [PorderConfWfEJB] confirm " + e.getMessage());
throw new ITMException(e);
}
return errString;
}
public String confirm(String pOrder, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException, ITMException
{
System.out.println("@@@@@@@@@@@@@@@@@@@@ PorderConfWfEJB : confirm @@@@@@@@@@@@@@@@");
String userId = "";
String errString = "";
String transDB = "";
ValidatorEJB validatorEJB = null;
ITMDBAccessEJB itmDBAccessEJB = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
PreparedStatement pStmt = null;
ResultSet rs = null;
String sql = "";
String status = "",confirmed = "",retString = "",wf_status = "";
String[] authencate = new String[2];
authencate[0] = "";
authencate[1] = "";
boolean isError = false;
try {
itmDBAccessEJB = new ITMDBAccessEJB();
validatorEJB = new ValidatorEJB();
//conn = getConnection();
if(userInfoStr != null && userInfoStr.trim().length() > 0)
{
UserInfoBean userInfo = new UserInfoBean(userInfoStr);
transDB = userInfo.getTransDB();
}
if (transDB != null && transDB.trim().length() > 0)
{
conn = connDriver.getConnectDB(transDB);
}
else
{
conn = connDriver.getConnectDB("DriverITM");
}
//connDriver = null;
conn.setAutoCommit(false);
userId = validatorEJB.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
System.out.println("tran_id ..> " + pOrder+" userId: "+userId+" xtraParams: "+xtraParams+" forcedFlag: "+forcedFlag);
sql = "SELECT status,confirmed,workflow_status from porder WHERE purc_order = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, pOrder);
rs = pStmt.executeQuery();
if (rs.next())
{
confirmed = checkNull(rs.getString("confirmed"));
status = checkNull(rs.getString("status"));
wf_status = checkNull(rs.getString("workflow_status"));
}
closePstmtRs(pStmt, rs);
if(!"Y".equalsIgnoreCase(confirmed))
{
if("X".equalsIgnoreCase(status) || "C".equalsIgnoreCase(status))
{
errString = new ITMDBAccessEJB().getErrorString("", "VTWFCLOCAN", "");
}
else if ("O".equalsIgnoreCase(status) || "".equalsIgnoreCase(status))
{
if("O".equalsIgnoreCase(wf_status) || "R".equalsIgnoreCase(wf_status) || "".equalsIgnoreCase(wf_status))
{
GenericWorkflowClass wfGenericClass = new GenericWorkflowClass();
retString = wfGenericClass.invokeWorkflow(conn, pOrder, xtraParams, "w_porder", "porder");
if ("success".equalsIgnoreCase(retString)) {
sql = "UPDATE PORDER SET workflow_status = 'S' WHERE PURC_ORDER = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, pOrder);
int updCount = pStmt.executeUpdate();
closePstmtRs(pStmt, rs);
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("", "VFMWRKFLWF", "");
}
}
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("PorderConfWfEJB: confirm: Connection Rollback");
} else {
conn.commit();
System.out.println("PorderConfWfEJB: confirm: Connection Commit");
}
conn.close();
conn = null;
} catch (Exception e) {
e.printStackTrace();
}
}
}
return errString;
}
public String rejection(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
String userInfoStr = "";
String errString = "";
try
{
userInfoStr = rejection(tranId, xtraParams, forcedFlag, userInfoStr);
System.out.println("userInfoStr of rejection::::: " +userInfoStr);
}
catch(Exception e)
{
System.out.println("Exception in [PorderConfWfEJB] rejection " + e.getMessage());
throw new ITMException(e);
}
return errString;
}
public String rejection(String pOrder, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException
{
System.out.println("================ PorderConfWfEJB : rejection ================");
String userId = "";
String errString = "";
ValidatorEJB validatorEJB = null;
ITMDBAccessEJB itmDBAccessEJB = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
PreparedStatement pStmt = null;
ResultSet rs = null;
String sql = "";
String transDB = "";
String status = "",confirmed = "",retString = "", wf_status = "";
String loginEmpCode="";
String[] authencate = new String[2];
authencate[0] = "";
authencate[1] = "";
boolean isError = false;
try {
itmDBAccessEJB = new ITMDBAccessEJB();
validatorEJB = new ValidatorEJB();
//conn = getConnection();
if(userInfoStr != null && userInfoStr.trim().length() > 0)
{
UserInfoBean userInfo = new UserInfoBean(userInfoStr);
transDB = userInfo.getTransDB();
}
if (transDB != null && transDB.trim().length() > 0)
{
conn = connDriver.getConnectDB(transDB);
}
else
{
conn = connDriver.getConnectDB("DriverITM");
}
//connDriver = null;
conn.setAutoCommit(false);
loginEmpCode = validatorEJB.getValueFromXTRA_PARAMS(xtraParams, "loginEmpCode");
if(loginEmpCode == null || loginEmpCode.trim().length() == 0)
{
errString = new ITMDBAccessEJB().getErrorString("", "EMPAPRV", "");
return errString;
}
//userId = validatorEJB.getValueFromXTRA_PARAMS(xtraParams, "loginCode");
System.out.println("pOrder ..> " +pOrder+" loginEmpCode: "+loginEmpCode+" xtraParams: "+xtraParams+" forcedFlag: "+forcedFlag);
pOrder = checkNull(pOrder);
sql = "SELECT status,confirmed,workflow_status from porder WHERE purc_order = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, pOrder);
rs = pStmt.executeQuery();
if (rs.next())
{
confirmed = checkNull(rs.getString("confirmed"));
status = checkNull(rs.getString("status"));
wf_status = checkNull(rs.getString("workflow_status"));
}
closePstmtRs(pStmt, rs);
if(!"Y".equalsIgnoreCase(confirmed))
{
/*if("X".equalsIgnoreCase(status) || "C".equalsIgnoreCase(status))
{
errString = new ITMDBAccessEJB().getErrorString("", "VTWFCLOCAN", "");
}*/
if ("O".equalsIgnoreCase(wf_status) || "R".equalsIgnoreCase(wf_status) || "S".equalsIgnoreCase(wf_status) || "".equalsIgnoreCase(wf_status))
{
sql = "UPDATE PORDER SET WORKFLOW_STATUS = 'O' WHERE PURC_ORDER = ? ";
pStmt = conn.prepareStatement(sql);
pStmt.setString(1, pOrder);
int updCount = pStmt.executeUpdate();
closePstmtRs(pStmt, rs);
if (updCount > 0)
{
retString="Y";
errString = new ITMDBAccessEJB().getErrorString("", "VFMWFOPN", "");
}
else
{
errString = new ITMDBAccessEJB().getErrorString("", "VFMWFFAIL", "");
isError=true;
}
}
else
{
errString = new ITMDBAccessEJB().getErrorString("", "VTMWFALINT", "");
}
}
else
{
errString = new ITMDBAccessEJB().getErrorString("", "VFMWFCONFN", "");
}
}
catch (Exception e)
{
isError = true;
System.out.println("Exception: rejection method of PorderConfWfEJB..> " + 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("PorderConfWfEJB: rejection: Connection Rollback");
}
else
{
conn.commit();
System.out.println("PorderConfWfEJB: rejection: Connection Commit");
}
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;
}
private void closePstmtRs(PreparedStatement pStmt, ResultSet rs)
{
if (rs != null) {
try {
rs.close();
} catch (SQLException e) {
e.printStackTrace();
}
rs = null;
}
if (pStmt != null) {
try {
pStmt.close();
} catch (SQLException localSQLException1) {
}
pStmt = null;
}
}
}
webitm-dis/ibase/webitm/ejb/dis/adv/PorderConfWfEJBLocal.java 0 → 100644
View file @ 040ccc33
package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
import javax.ejb.Local;
import ibase.webitm.ejb.ActionHandlerLocal;
import ibase.webitm.utility.ITMException;
@Local
public interface PorderConfWfEJBLocal extends ActionHandlerLocal
{
public String confirm(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
public String confirm(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException;
public String rejection(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
public String rejection(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException;
}
webitm-dis/ibase/webitm/ejb/dis/adv/PorderConfWfEJBRemote.java 0 → 100644
View file @ 040ccc33
package ibase.webitm.ejb.dis.adv;
import java.rmi.RemoteException;
import javax.ejb.Remote;
import ibase.webitm.ejb.ActionHandlerRemote;
import ibase.webitm.utility.ITMException;
@Remote
public interface PorderConfWfEJBRemote extends ActionHandlerRemote
{
public String confirm(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
public String confirm(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException;
public String rejection(String paramString1, String paramString2,String paramString3) throws RemoteException, ITMException;
public String rejection(String tranId, String xtraParams, String forcedFlag, String userInfoStr) throws RemoteException,ITMException;
}
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