Skip to content

B
business-java
Commit c3c9c668 authored by dsawant's avatar dsawant
Browse files
Options

campaign process created 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@95180 ce508802-f39f-4f6c-b175-0d175dae99d5
parent b92eab7b
Hide whitespace changes
Inline Side-by-side
Showing with 469 additions and 205 deletions
webitm-mfg/ibase/webitm/ejb/mfg/WorderCampaign.java
View file @ c3c9c668
package ibase.webitm.ejb.mfg; package ibase.webitm.ejb.mfg;
import ibase.system.config.ConnDriver; import ibase.system.config.ConnDriver;
import ibase.utility.CommonConstants; import ibase.utility.CommonConstants;
import ibase.webitm.ejb.ActionHandlerEJB;
import ibase.webitm.ejb.ITMDBAccessEJB; import ibase.webitm.ejb.ITMDBAccessEJB;
import ibase.webitm.ejb.ITMDBAccessLocal; import ibase.webitm.ejb.ITMDBAccessLocal;
import ibase.webitm.ejb.ProcessEJB;
import ibase.webitm.utility.GenericUtility; import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import ibase.webitm.utility.TransIDGenerator; import ibase.webitm.utility.TransIDGenerator;
...@@ -15,147 +17,414 @@ import java.sql.PreparedStatement; ...@@ -15,147 +17,414 @@ import java.sql.PreparedStatement;
import java.sql.ResultSet; import java.sql.ResultSet;
import java.sql.SQLException; import java.sql.SQLException;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.Calendar; import java.util.*;
import javax.ejb.Stateless;
import javax.ejb.Stateless; // added for ejb3 import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
@Stateless @Stateless
public class WorderCampaign extends ActionHandlerEJB implements WorderCampaignLocal,WorderCampaignRemote{ public class WorderCampaign extends ProcessEJB implements WorderCampaignLocal, WorderCampaignRemote {
GenericUtility genericUtility = GenericUtility.getInstance();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
@Override
public String getData(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException, ITMException {
System.out.println("^^^^^^^ Inside ReceiptGenerationProcess -> GetData Method 1 ^^^^^^^");
Document detailDom = null;
Document headerDom = null;
String retString = "";
System.out.println("XMLSTRING ..> " + xmlString);
System.out.println("XMLSTRING2 ..> " + xmlString2);
try {
if (xmlString != null && xmlString.trim().length() != 0) {
headerDom = genericUtility.parseString(xmlString);
}
if (xmlString2 != null && xmlString2.trim().length() != 0) {
detailDom = genericUtility.parseString(xmlString2);
}
retString = getData(headerDom, detailDom, windowName, xtraParams);
} catch (Exception e) {
System.out.println("Exception ReceiptGenerationProcess GetData Method 1");
e.printStackTrace();
retString = itmDBAccessEJB.getErrorString("", "VTPFTEXE", "", 1); // failed to execute
throw new ITMException(e);
}
return retString;
}
@Override
public String getData(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException, ITMException {
System.out.println("^^^^^^^ Inside ReceiptGenerationProcess -> GetData Method 2 ^^^^^^^");
String retString = "";
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
// Node childNode = null;
ConnDriver connDriver = null;
Connection conn = null;
PreparedStatement pStmt = null;
ResultSet rs = null;
String sql = "";
ITMDBAccessEJB itmDBAccessEJB = null;
boolean isError = false;
SimpleDateFormat sdf = null;
StringBuffer resultData = new StringBuffer();
boolean dataFound = false;
String siteCode = "", fromDate = "", toDate = "", loanNoFrom = "", loanNoTo = "";
String loanNo = "", applName = "", chequeNo = "", payMode = "", ifscCode = "", bankCode = "";
Double emiAmt = 0.0;
String pdcNo = "";
int lineNo = -1;
java.sql.Date fromDateDtSql = null, toDateDtSql = null;
java.util.Date fromDateDtUtil = null, toDateDtUtil = null;
String emiDateDtSql = "", chequeDateDtSQL = "";
String ordDate="",relDate="",dueDate="",workOrder="",tranID="",orderType="",itemCode="",status="",statDate="",unitStd="",tranMps="",
acctWp="",cctrWp="",shdscr="",lotNo="",bomCode="",phyAtt1="",phyAtt2="",phyAtt3="",phyAtt4="",phyAtt5="",phyAtt6="",
addUser="",addTerm="",addDate="",chgDate="",chgUser="",chgTerm="",valMfg="",campNo="";
Double quantity = 0.0,currQty=0.0,conQstd=0.0,stdQty=0.0,quanMps=0.0;
SimpleDateFormat simpleDateFormatObj;
try {
sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
itmDBAccessEJB = new ITMDBAccessEJB();
parentNodeList = detailDom.getElementsByTagName("Detail1");
parentNode = parentNodeList.item(0);
childNodeList = parentNode.getChildNodes();
for (int i = 0; i < childNodeList.getLength(); i++) {
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException
{
System.out.println("--------------confirm method of WorderCampaign------------- : "+tranId); fromDate = genericUtility.getColumnValue("date_from", headerDom);
String retString = ""; toDate = genericUtility.getColumnValue("date_to", headerDom);
try System.out.println(">>>>>>fromDate"+fromDate+">>>>D"+toDate);
{ fromDateDtUtil = sdf.parse(fromDate);
System.out.println("--------------CONFIRM()"); fromDateDtSql = new java.sql.Date(fromDateDtUtil.getTime());
retString = campaign(tranId,xtraParams,forcedFlag); toDateDtUtil = sdf.parse(toDate);
System.out.println("retString >>>>"+retString); toDateDtSql = new java.sql.Date(toDateDtUtil.getTime());
}
sql ="SELECT WORKORDER.WORK_ORDER,WORKORDER.TRAN_ID,"
+ "WORKORDER.ORDER_TYPE,"
+ "WORKORDER.ITEM_CODE,WORKORDER.SITE_CODE,WORKORDER.QUANTITY,"
+ "WORKORDER.ORD_DATE,WORKORDER.REL_DATE,WORKORDER.DUE_DATE,WORKORDER.STATUS,WORKORDER.STATUS_DATE,WORKORDER.ACCT_CODE__WP,"
+ "WORKORDER.CCTR_CODE__WP,ITEM.SH_DESCR,WORKORDER.LOT_NO,WORKORDER.BOM_CODE,WORKORDER.CURRENT_BATCH_QTY,WORKORDER.VAL_MFG_TAXTRAN,"
+ "WORKORDER.UNIT__STD,WORKORDER.CONV__QTY_STDUOM,WORKORDER.STD_QTY,WORKORDER.QUANTITY__MPS,"
+ "ITEM.PHY_ATTRIB_1,ITEM.PHY_ATTRIB_2,ITEM.PHY_ATTRIB_3,"
+ "ITEM.PHY_ATTRIB_4,ITEM.PHY_ATTRIB_5,ITEM.PHY_ATTRIB_6,"
+ "WORKORDER.TRAN_ID__MPS,"
+ "WORKORDER.ADD_DATE,WORKORDER.ADD_USER,WORKORDER.ADD_TERM,WORKORDER.CHG_DATE,"
+ "WORKORDER.CHG_USER,WORKORDER.CHG_TERM,WORKORDER.CAMPGN_NO"
+ " FROM"
+ " WORKORDER WORKORDER,ITEM ITEM WHERE ( WORKORDER.ITEM_CODE = ITEM.ITEM_CODE ) AND ( WORKORDER.ORD_DATE >= ? ) AND ( WORKORDER.ORD_DATE <= ? )";
/*sql = "SELECT WORKORDER.WORK_ORDER,WORKORDER.TRAN_ID,WORKORDER.ORDER_TYPE,WORKORDER.ITEM_CODE,WORKORDER.SITE_CODE,"+
"WORKORDER.QUANTITY,WORKORDER.ORD_DATE,WORKORDER.REL_DATE,WORKORDER.DUE_DATE,WORKORDER.STATUS,WORKORDER.STATUS_DATE,"+
"WORKORDER.ACCT_CODE__WP,WORKORDER.CCTR_CODE__WP,ITEM.SH_DESCR,WORKORDER.LOT_NO,WORKORDER.BOM_CODE,"+
"WORKORDER.CURRENT_BATCH_QTY,WORKORDER.VAL_MFG_TAXTRAN,WORKORDER.UNIT__STD,WORKORDER.CONV__QTY_STDUOM,WORKORDER.STD_QTY,"+
"WORKORDER.TRAN_ID__MPS,WORKORDER.QUANTITY__MPS FROM "+
"WORKORDER WORKORDER,ITEM ITEM WHERE (WORKORDER.ITEM_CODE = ITEM.ITEM_CODE ) AND "+
"( WORKORDER.ORD_DATE >= ? ) AND ( WORKORDER.ORD_DATE <= ? )";*/
pStmt = conn.prepareStatement(sql);
pStmt.setDate(1, fromDateDtSql);
pStmt.setDate(2, toDateDtSql);
rs = pStmt.executeQuery();
while (rs.next()) {
dataFound = true;
tranID = rs.getString("TRAN_ID") == null ? "" : rs.getString("TRAN_ID");
workOrder = rs.getString("WORK_ORDER") == null ? "" : rs.getString("WORK_ORDER").trim();
bomCode = rs.getString("BOM_CODE") == null ? "" : rs.getString("BOM_CODE").trim();
itemCode = rs.getString("ITEM_CODE") == null ? "" : rs.getString("ITEM_CODE").trim();
siteCode = rs.getString("SITE_CODE") == null ? "" : rs.getString("SITE_CODE").trim();
shdscr = rs.getString("SH_DESCR") == null ? "" : rs.getString("SH_DESCR").trim();
lotNo = rs.getString("LOT_NO") == null ? "" : rs.getString("LOT_NO").trim();
quantity = rs.getString("QUANTITY") == null ? 0.0 : rs.getDouble("QUANTITY");
tranMps = rs.getString("TRAN_ID__MPS") == null ? "" : rs.getString("TRAN_ID__MPS");
status = rs.getString("STATUS") == null ? "" : rs.getString("STATUS").trim();
statDate = rs.getString("STATUS_DATE") == null ? "" : sdf.format(rs.getDate("STATUS_DATE"));
relDate = rs.getString("REL_DATE") == null ? "" : sdf.format(rs.getDate("REL_DATE"));
dueDate = rs.getString("DUE_DATE") == null ? "" : sdf.format(rs.getDate("DUE_DATE"));
orderType = rs.getString("ORDER_TYPE") == null ? "" : rs.getString("ORDER_TYPE").trim();
ordDate = rs.getString("ORD_DATE") == null ? "" : sdf.format(rs.getDate("ORD_DATE"));
acctWp = rs.getString("ACCT_CODE__WP") == null ? "" : rs.getString("ACCT_CODE__WP").trim();
cctrWp = rs.getString("CCTR_CODE__WP") == null ? "" : rs.getString("CCTR_CODE__WP").trim();
currQty = rs.getString("CURRENT_BATCH_QTY") == null ? 0.0 : rs.getDouble("CURRENT_BATCH_QTY");
valMfg = rs.getString("VAL_MFG_TAXTRAN") == null ? "" : rs.getString("VAL_MFG_TAXTRAN").trim();
unitStd = rs.getString("UNIT__STD") == null ? "" : rs.getString("UNIT__STD").trim();
stdQty = rs.getString("STD_QTY") == null ? 0.0 : rs.getDouble("STD_QTY");
conQstd = rs.getString("CONV__QTY_STDUOM") == null ? 0.0 : rs.getDouble("CONV__QTY_STDUOM");
quanMps = rs.getString("QUANTITY__MPS") == null ? 0.0 : rs.getDouble("QUANTITY__MPS");
phyAtt1 = rs.getString("PHY_ATTRIB_1") == null ? "" : rs.getString("PHY_ATTRIB_1").trim();
phyAtt2 = rs.getString("PHY_ATTRIB_2") == null ? "" : rs.getString("PHY_ATTRIB_2").trim();
phyAtt3 = rs.getString("PHY_ATTRIB_3") == null ? "" : rs.getString("PHY_ATTRIB_3").trim();
phyAtt4 = rs.getString("PHY_ATTRIB_4") == null ? "" : rs.getString("PHY_ATTRIB_4").trim();
phyAtt5 = rs.getString("PHY_ATTRIB_5") == null ? "" : rs.getString("PHY_ATTRIB_5").trim();
phyAtt6 = rs.getString("PHY_ATTRIB_6") == null ? "" : rs.getString("PHY_ATTRIB_6").trim();
addDate = rs.getString("ADD_DATE") == null ? "" : sdf.format(rs.getDate("ADD_DATE"));
addUser = rs.getString("ADD_USER") == null ? "" : rs.getString("ADD_USER").trim();
addTerm = rs.getString("ADD_TERM") == null ? "" : rs.getString("ADD_TERM").trim();
chgDate = rs.getString("CHG_DATE") == null ? "" : sdf.format(rs.getDate("CHG_DATE"));
chgUser = rs.getString("CHG_USER") == null ? "" : rs.getString("CHG_USER").trim();
chgTerm = rs.getString("CHG_TERM") == null ? "" : rs.getString("CHG_TERM").trim();
campNo = rs.getString("CAMPGN_NO") == null ? "" : rs.getString("CAMPGN_NO").trim();
resultData.append(tranID).append("\t");
resultData.append(workOrder).append("\t");
resultData.append(bomCode).append("\t");
resultData.append(itemCode).append("\t");
resultData.append(shdscr).append("\t");
resultData.append(lotNo).append("\t");
resultData.append(quantity).append("\t");
resultData.append(tranMps).append("\t");
resultData.append(status).append("\t");
resultData.append(statDate).append("\t");
resultData.append(relDate).append("\t");
resultData.append(dueDate).append("\t");
resultData.append(orderType).append("\t");
resultData.append(ordDate).append("\t");
resultData.append(siteCode).append("\t");
resultData.append(acctWp).append("\t");
resultData.append(cctrWp).append("\t");
resultData.append(currQty).append("\t");
resultData.append(valMfg).append("\t");
resultData.append(unitStd).append("\t");
resultData.append(stdQty).append("\t");
resultData.append(conQstd).append("\t");
resultData.append(phyAtt1).append("\t");
resultData.append(phyAtt2).append("\t");
resultData.append(phyAtt3).append("\t");
resultData.append(phyAtt4).append("\t");
resultData.append(phyAtt5).append("\t");
resultData.append(phyAtt6).append("\t");
resultData.append(chgDate).append("\t");
resultData.append(chgUser).append("\t");
resultData.append(chgTerm).append("\t");
resultData.append(addDate).append("\t");
resultData.append(addUser).append("\t");
resultData.append(addTerm).append("\t");
resultData.append(campNo).append("\t");
resultData.append("\n");
}
if(!rs.next())
{
System.out.println(">>>>>faildsssss");
retString = itmDBAccessEJB.getErrorString("", "", "", "", conn);
}
rs.close();
rs = null;
pStmt.close();
pStmt = null;
} catch (Exception e) {
isError = true;
throw new ITMException(e);
} finally {
try {
if (conn != null) {
if (isError) {
retString = itmDBAccessEJB.getErrorString("", "VTPFTEXE", "", "", conn); // failed to execute
} else {
retString = resultData.toString();
System.out.println("RETSTRING ..> " + retString);
if (!dataFound) {
retString = itmDBAccessEJB.getErrorString("", "VTVFMNOREC", "", "", conn); // NO RECORD FOUND
}
}
conn.close();
conn = null;
} }
catch(Exception e) if (rs != null) {
{ rs.close();
System.out.println("Exception :WorderCampaign :confirm():" + e.getMessage() + ":"); rs = null;
retString = GenericUtility.getInstance().createErrorString(e);
e.printStackTrace();
} }
if (pStmt != null) {
return retString; pStmt.close();
pStmt = null;
}
} catch (Exception e) {
retString = e.getMessage();
throw new ITMException(e);
}
} }
return retString;
}
@Override
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException, ITMException {
System.out.println("^^^^^^^ Inside process -> Process Method 1 ^^^^^^^");
Document detailDom = null;
Document headerDom = null;
String retString = "";
System.out.println("XMLSTRING ..> " + xmlString);
System.out.println("XMLSTRING2 ..> " + xmlString2);
try {
if (xmlString != null && xmlString.trim().length() != 0) {
headerDom = genericUtility.parseString(xmlString);
}
if (xmlString2 != null && xmlString2.trim().length() != 0) {
detailDom = genericUtility.parseString(xmlString2);
}
retString = process(headerDom, detailDom, windowName, xtraParams);
} catch (Exception e) {
System.out.println("Exception process Process Method 1");
e.printStackTrace();
retString = itmDBAccessEJB.getErrorString("", "VTPFTEXE", "", 1); // failed to execute
throw new ITMException(e);
}
return retString;
}
@Override
public String process(Document headerDom, Document detailDom, String windowName, String xtraParams) throws RemoteException, ITMException {
System.out.println("^^^^^^^ Inside process -> Process Method 2 ^^^^^^^");
String retString = "";
NodeList parentNodeList = null;
NodeList childNodeList = null;
Node parentNode = null;
Node childNode = null;
ConnDriver connDriver = null;
Connection conn = null;
PreparedStatement pStmt = null;
ResultSet rs = null;
String sql = "";
ITMDBAccessEJB itmDBAccessEJB = null;
boolean isError = false;
SimpleDateFormat sdf = null;
ArrayList<String> headerList = new ArrayList<String>();
String errCode = "";
int childNodeListLength = 0;
String childNodeName = "";
String receiptNo = "", loanNo = "", applName = "", chequeNo = "", bankCodeDep = "", payMode = "", ifscCode = "";
double emiAmt = 0;
String pdcNo = "", lineNoStr = "", confirmed = "";
int lineNo = -1;
String custCode = "";
java.sql.Date chequeDateSql = null;
String tranDate = "",tranID="";
PreparedStatement pstmt=null;
String errString="",loginCode="",loginSite="",systemDate="";
Calendar currentDate;
SimpleDateFormat simpleDateFormatObj;
//String keyString = null;
//ConnDriver ConnDriver = new ConnDriver();
int count=0;
ITMDBAccessLocal itmdbAccess=new ITMDBAccessEJB();
String wostatus="",worder="",chgTerm="",chgUser="",utranid="";
public String campaign(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException try {
{ connDriver = new ConnDriver();
conn = connDriver.getConnectDB("DriverITM");
conn.setAutoCommit(false);
connDriver = null;
itmDBAccessEJB = new ITMDBAccessEJB();
sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
parentNodeList = detailDom.getElementsByTagName("Detail2");
for (int i = 0; i < parentNodeList.getLength(); i++) {
parentNode = parentNodeList.item(i);
childNodeList = parentNode.getChildNodes();
childNodeListLength = childNodeList.getLength();
for (int j = 0; j < childNodeListLength; j++) {
childNode = childNodeList.item(j);
childNodeName = childNode.getNodeName();
if (childNodeName.equals("tran_id")) {
tranID = childNode.getFirstChild() == null ? "" : childNode.getFirstChild().getNodeValue();
}
}
tranID = tranID == null ? "" : tranID.trim();
GenericUtility genericUtility = GenericUtility.getInstance();
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "chg_term");
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "chg_user");
System.out.println(">>>>>>>chgTerm and t"+chgTerm+">>>>> chgUser"+chgUser);
currentDate = Calendar.getInstance();
simpleDateFormatObj = new SimpleDateFormat(genericUtility.getApplDateFormat());
systemDate = simpleDateFormatObj.format(currentDate.getTime());
System.out.println("Now the date is :=> " + systemDate);
System.out.println("in >> campaign()"); /*loginCode=GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"loginCode");
System.out.println("campaign() called"+tranId); loginCode=loginCode==null ? "" :loginCode.trim();*/
ResultSet rs=null; loginSite = GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
Connection conn=null; System.out.println("loginCode---->>["+loginCode+"]");
PreparedStatement pstmt=null; conn.setAutoCommit(false);
String errString="",sql="",loginCode="",loginSite="",systemDate="",utranid="";
Calendar currentDate;
SimpleDateFormat simpleDateFormatObj; System.out.println("loginCode"+loginCode+"<<<<<<<loginSite"+loginSite);
//String keyString = null;
//ConnDriver ConnDriver = new ConnDriver(); if(utranid.trim().length() <= 0)
int count=0;
ITMDBAccessLocal itmdbAccess=new ITMDBAccessEJB();
String wostatus="",worder="",chgTerm="",chgUser="";
try
{ {
utranid = generateTranId("w_worder", loginSite, conn);
}
System.out.println("GENERATED TRAN ID"+utranid);
sql = "select work_order from workorder where tran_id = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,tranID);
rs = pstmt.executeQuery();
if(rs.next())
{
worder = rs.getString(1) == null ? "":rs.getString(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
System.out.println("WORK ORDER NO"+worder);
sql = "select status from workorder where tran_id = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,tranID);
rs = pstmt.executeQuery();
if(rs.next())
{
wostatus = rs.getString(1) == null ? "":rs.getString(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
System.out.println("wostatusWEWEWEE >>>>>>>>>>>>>>>>>>."+wostatus);
if(wostatus.equalsIgnoreCase("P") || wostatus.equalsIgnoreCase("M") || wostatus.equalsIgnoreCase("U"))
{
ConnDriver connDriver = null; System.out.println("ENTER IN STATUS CHECK >>>>>");
connDriver = new ConnDriver(); sql = "UPDATE WORKORDER SET CAMPGN_NO = ? WHERE WORK_ORDER = ?";
conn = connDriver.getConnectDB("DriverITM");
GenericUtility genericUtility = GenericUtility.getInstance();
chgTerm = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "chg_term");
chgUser = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "chg_user");
System.out.println(">>>>>>>chgTerm and t"+chgTerm+">>>>> chgUser"+chgUser);
currentDate = Calendar.getInstance();
simpleDateFormatObj = new SimpleDateFormat(genericUtility.getApplDateFormat());
systemDate = simpleDateFormatObj.format(currentDate.getTime());
System.out.println("Now the date is :=> " + systemDate);
/*loginCode=GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"loginCode");
loginCode=loginCode==null ? "" :loginCode.trim();*/
loginSite = GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams, "loginSiteCode");
System.out.println("loginCode---->>["+loginCode+"]");
conn.setAutoCommit(false);
System.out.println("loginCode"+loginCode+"<<<<<<<loginSite"+loginSite);
utranid = generateTranId("w_worder", loginSite, conn);
System.out.println("GENERATED TRAN ID"+utranid);
sql = "select work_order from workorder where tran_id = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
worder = rs.getString(1) == null ? "":rs.getString(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
System.out.println("WORK ORDER NO"+worder);
sql = "select status from workorder where tran_id = ?";
pstmt=conn.prepareStatement(sql);
pstmt.setString(1,tranId);
rs = pstmt.executeQuery();
if(rs.next())
{
wostatus = rs.getString(1) == null ? "":rs.getString(1);
}
pstmt.close();
rs.close();
pstmt = null;
rs = null;
System.out.println("wostatusWEWEWEE >>>>>>>>>>>>>>>>>>."+wostatus);
if(wostatus.equalsIgnoreCase("P") || wostatus.equalsIgnoreCase("M") || wostatus.equalsIgnoreCase("U"))
{
System.out.println("ENTER IN STATUS CHECK >>>>>");
sql = "UPDATE WORKORDER SET CAMPGN_NO = ? WHERE WORK_ORDER = ?";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,utranid);
pstmt.setString(2,worder);
count = pstmt.executeUpdate();
if(count < 1)
{
System.out.println("updation of record is failed");
}
else
{
conn.commit();
}
pstmt.close();
pstmt = null;
System.out.println("NO. OF RECORDS UPDATED FOR CURRENT PERIODE.. "+count);
sql = "INSERT INTO WORDER_CAMPAIGN (WORK_ORDER,CAMPGN_NO,CHG_DATE,CHG_USER,CHG_TERM) VALUES (?,?,?,?,?)";
pstmt = conn.prepareStatement(sql); pstmt = conn.prepareStatement(sql);
pstmt.setString(1,worder); pstmt.setString(1,utranid);
pstmt.setString(2,utranid); pstmt.setString(2,worder);
pstmt.setString(3,systemDate);
pstmt.setString(4,chgUser);
pstmt.setString(5,chgTerm);
count = pstmt.executeUpdate(); count = pstmt.executeUpdate();
if(count < 1) if(count < 1)
{ {
System.out.println("Insertion of record is failed"); System.out.println("updation of record is failed");
} }
else else
{ {
...@@ -164,80 +433,75 @@ public String confirm(String tranId, String xtraParams, String forcedFlag) throw ...@@ -164,80 +433,75 @@ public String confirm(String tranId, String xtraParams, String forcedFlag) throw
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
System.out.println("NO. OF RECORDS INSERTED FOR CURRENT PERIODE.. "+count); System.out.println("NO. OF RECORDS UPDATED FOR CURRENT PERIODE.. "+count);
}
}catch(SQLException se)
{
System.out.println("SQLException : class StockValAdjTranConf : ");
se.printStackTrace();
try
{
conn.rollback();
errString = itmdbAccess.getErrorString("", "STKVNCONF", "", "", conn);
return errString;
}
catch(Exception e){
System.out.println("Exception : Occure during rollback........");e.printStackTrace();
}
}
catch(Exception e)
{
try
{
conn.rollback();
errString = itmdbAccess.getErrorString("", "STKVNCONF", "", "", conn);
return errString;
}
catch (Exception e1)
{
}
e.printStackTrace();
System.out.println("Exception Class [StockValAdjTranConf]::"+e.getMessage());
}
finally
{ sql = "INSERT INTO WORDER_CAMPAIGN (WORK_ORDER,CAMPGN_NO,CHG_DATE,CHG_USER,CHG_TERM) VALUES (?,?,?,?,?)";
try pstmt = conn.prepareStatement(sql);
{ pstmt.setString(1,worder);
if(pstmt != null) pstmt.setString(2,utranid);
{ pstmt.setString(3,systemDate);
pstmt.close(); pstmt.setString(4,chgUser);
pstmt = null; pstmt.setString(5,chgTerm);
} count = pstmt.executeUpdate();
if (conn!=null) if(count < 1)
{ {
conn.close(); System.out.println("Insertion of record is failed");
conn=null;
}
} }
catch(Exception e) else
{ {
System.out.println(e.getMessage());
e.printStackTrace();
conn.commit();
System.out.println(">>>>>process completed");
errCode = ""; // generated successfully
retString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn);
} }
}
errString = itmdbAccess.getErrorString("","STKVACONF",loginCode);
if(errString.indexOf("STKVACONF") > -1){
System.out.println("FINAL STATUS CALLED"); pstmt.close();
pstmt = null;
System.out.println("NO. OF RECORDS INSERTED FOR CURRENT PERIODE.. "+count);
}
System.out.println("[WorderCampaign]errstring :"+errString); }
return errString; }
}catch (Exception e) {
isError = true;
errCode = "VTPFTEXE"; // failed to execute
retString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn);
e.printStackTrace();
throw new ITMException(e);
} finally {
try {
if (conn != null) {
if (isError) {
conn.rollback();
} else {
conn.commit();
}
conn.close();
conn = null;
}
if (pStmt != null) {
pStmt.close();
pStmt = null;
}
} catch (Exception e) {
e.printStackTrace();
throw new ITMException(e);
}
} }
return retString;
}
private String trimString(String s) {
s = s == null ? "" : s.trim();
return s;
}
public static String generateTranId(String windowName, String siteCode, Connection conn) throws ITMException { public static String generateTranId(String windowName, String siteCode, Connection conn) throws ITMException {
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
ResultSet rs = null; ResultSet rs = null;
...@@ -307,6 +571,4 @@ public String confirm(String tranId, String xtraParams, String forcedFlag) throw ...@@ -307,6 +571,4 @@ public String confirm(String tranId, String xtraParams, String forcedFlag) throw
} }
return tranId; return tranId;
} }
}
\ No newline at end of file
}
webitm-mfg/ibase/webitm/ejb/mfg/WorderCampaignLocal.java
View file @ c3c9c668
package ibase.webitm.ejb.mfg; package ibase.webitm.ejb.mfg;
import ibase.webitm.ejb.ActionHandlerLocal;
import ibase.webitm.utility.ITMException;
import java.rmi.RemoteException; import java.rmi.RemoteException;
import ibase.webitm.utility.ITMException;
import org.w3c.dom.Document;
import ibase.webitm.ejb.ProcessLocal;
import javax.ejb.Local; import javax.ejb.Local;
@Local @Local
public interface WorderCampaignLocal extends ActionHandlerLocal public interface WorderCampaignLocal extends ProcessLocal {
{ public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException, ITMException;
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException;
} public String process(Document dom, Document dom2, String windowName, String xtraParams) throws RemoteException, ITMException;
\ No newline at end of file }
webitm-mfg/ibase/webitm/ejb/mfg/WorderCampaignRemote.java
View file @ c3c9c668
package ibase.webitm.ejb.mfg; package ibase.webitm.ejb.mfg;
import java.rmi.RemoteException;
import ibase.webitm.ejb.ActionHandlerRemote; import org.w3c.dom.Document;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.ITMException;
import javax.ejb.Remote; import javax.ejb.Remote;
import ibase.webitm.ejb.ProcessRemote;
import java.rmi.RemoteException;
@Remote @Remote
public interface WorderCampaignRemote { public interface WorderCampaignRemote extends ProcessRemote {
public String process(String xmlString, String xmlString2, String windowName, String xtraParams) throws RemoteException, ITMException;
public String confirm(String tranId, String xtraParams, String forcedFlag) throws RemoteException,ITMException; public String process(Document dom, Document dom2, String windowName, String xtraParams) throws RemoteException, ITMException;
}
} \ No newline at end of file
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