Skip to content

B
business-java
Commit abaf44e2 authored by gahmad's avatar gahmad
Browse files
Options

changes made at sun for wms 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@91514 ce508802-f39f-4f6c-b175-0d175dae99d5
parent cf6c9117
Hide whitespace changes
Inline Side-by-side
Showing with 322 additions and 300 deletions
webitm-dis/.project 0 → 100755
View file @ abaf44e2
<?xml version="1.0" encoding="UTF-8"?>
<projectDescription>
<name>webitm-dis</name>
<comment></comment>
<projects>
</projects>
<buildSpec>
</buildSpec>
<natures>
</natures>
</projectDescription>
webitm-dis/ibase/webitm/ejb/dis/InvHoldGen.java
View file @ abaf44e2
/* /*
* PURPOSE : Inv Hold Generation * PURPOSE : Inv Hold Generation
* Author: Sandesh * Author: Sandesh
* Date: 30/08/11 * Date: 30/08/11
*/ */
package ibase.webitm.ejb.dis; package ibase.webitm.ejb.dis;
import ibase.ejb.*; import ibase.ejb.*;
import ibase.utility.*; import ibase.utility.*;
import ibase.system.config.*; import ibase.system.config.*;
import ibase.utility.BaseLogger; import ibase.utility.BaseLogger;
import ibase.webitm.ejb.*; import ibase.webitm.ejb.*;
import ibase.webitm.utility.GenericUtility; import ibase.webitm.ejb.dis.adv.*;
import ibase.webitm.utility.TransIDGenerator; import ibase.webitm.utility.GenericUtility;
import ibase.webitm.utility.ITMException; import ibase.webitm.utility.TransIDGenerator;
import ibase.utility.CommonConstants; import ibase.webitm.utility.ITMException;
import ibase.utility.CommonConstants;
import java.lang.*;
import java.io.*; import java.lang.*;
import java.rmi.RemoteException; import java.io.*;
import java.sql.*; import java.rmi.RemoteException;
import javax.ejb.*; import java.sql.*;
import java.text.*; import javax.ejb.*;
import java.util.*; import java.text.*;
import java.util.*;
import javax.xml.parsers.*;
import org.w3c.dom.*; import javax.xml.parsers.*;
import org.w3c.dom.*;
public class InvHoldGen
{ public class InvHoldGen
public String generateHoldTrans( String lockCode, String refID, String refSer, String siteCode, ArrayList stockList, String xtraParams, Connection conn )throws RemoteException,ITMException {
{ public String generateHoldTrans( String lockCode, String refID, String refSer, String siteCode, ArrayList stockList, String xtraParams, Connection conn )throws RemoteException,ITMException
String sql = ""; {
String confirmed = ""; String sql = "";
String itemCode = ""; String confirmed = "";
String locCode = ""; String itemCode = "";
String lotSl = ""; String locCode = "";
String lotNo = ""; String lotSl = "";
String chgUser = ""; String lotNo = "";
String chgTerm = ""; String chgUser = "";
String retString = ""; String chgTerm = "";
String tranId = ""; String retString = "";
java.sql.Timestamp chgDate = null,currDate = null; String tranId = "";
int lineNo = 0; java.sql.Timestamp chgDate = null,currDate = null;
int lineNo = 0;
boolean isError = false;
boolean isError = false;
PreparedStatement pstmtHold = null;
PreparedStatement pstmtHolddet = null; PreparedStatement pstmtHold = null;
PreparedStatement pstmtSel = null; PreparedStatement pstmtHolddet = null;
ResultSet rsSel = null; PreparedStatement pstmtSel = null;
java.util.Date date = null; ResultSet rsSel = null;
java.util.Date date = null;
try
{ try
if ( lockCode == null || lockCode.trim().length() == 0 ) {
{ if ( lockCode == null || lockCode.trim().length() == 0 )
return ""; {
} return "";
conn.setAutoCommit(false); }
//conn.setAutoCommit(false);
String holdInsertSql = "INSERT INTO INV_HOLD(TRAN_ID,TRAN_DATE,SITE_CODE,CONFIRMED,REF_ID,REF_SER,CHG_USER,CHG_DATE,CHG_TERM, LOCK_CODE) VALUES(?,?,?,?,?,?,?,?,?,?)";
String holdInsertSql = "INSERT INTO INV_HOLD(TRAN_ID,TRAN_DATE,SITE_CODE,CONFIRMED,REF_ID,REF_SER,CHG_USER,CHG_DATE,CHG_TERM, LOCK_CODE) VALUES(?,?,?,?,?,?,?,?,?,?)";
pstmtHold = conn.prepareStatement(holdInsertSql);
pstmtHold = conn.prepareStatement(holdInsertSql);
String holddetInsertSql = "INSERT INTO INV_HOLD_DET(TRAN_ID,LINE_NO,ITEM_CODE,SITE_CODE,LOC_CODE,LOT_NO,LOT_SL,HOLD_STATUS) VALUES(?,?,?,?,?,?,?,?)";
String holddetInsertSql = "INSERT INTO INV_HOLD_DET(TRAN_ID,LINE_NO,ITEM_CODE,SITE_CODE,LOC_CODE,LOT_NO,LOT_SL,HOLD_STATUS) VALUES(?,?,?,?,?,?,?,?)";
pstmtHolddet = conn.prepareStatement(holddetInsertSql);
GenericUtility genericUtility = GenericUtility.getInstance(); pstmtHolddet = conn.prepareStatement(holddetInsertSql);
GenericUtility genericUtility = GenericUtility.getInstance();
chgDate = new java.sql.Timestamp( System.currentTimeMillis() );
chgDate = new java.sql.Timestamp( System.currentTimeMillis() );
currDate = new java.sql.Timestamp(System.currentTimeMillis());
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat()); currDate = new java.sql.Timestamp(System.currentTimeMillis());
date = sdf.parse(currDate.toString()); SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getDBDateFormat());
chgDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0"); date = sdf.parse(currDate.toString());
chgDate = java.sql.Timestamp.valueOf(sdf.format(date).toString() + " 00:00:00.0");
String userId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" );
chgTerm = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "chgTerm" ); String userId = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "loginCode" );
chgTerm = genericUtility.getValueFromXTRA_PARAMS( xtraParams, "chgTerm" );
int updCnt = 0;
int updCnt = 0;
tranId = generateTranId( "w_inv_hold", conn );
tranId = generateTranId( "w_inv_hold", conn );
pstmtHold.setString( 1, tranId );
pstmtHold.setTimestamp( 2, currDate ); pstmtHold.setString( 1, tranId );
pstmtHold.setString( 3, siteCode ); pstmtHold.setTimestamp( 2, currDate );
pstmtHold.setString( 4, "N" ); pstmtHold.setString( 3, siteCode );
pstmtHold.setString( 5, refID ); pstmtHold.setString( 4, "N" );
pstmtHold.setString( 6, refSer ); pstmtHold.setString( 5, refID );
pstmtHold.setString( 7, userId ); pstmtHold.setString( 6, refSer );
pstmtHold.setTimestamp( 8, currDate ); pstmtHold.setString( 7, userId );
pstmtHold.setString( 9, chgTerm ); pstmtHold.setTimestamp( 8, currDate );
pstmtHold.setString( 10, lockCode ); pstmtHold.setString( 9, chgTerm );
pstmtHold.setString( 10, lockCode );
updCnt = pstmtHold.executeUpdate();
pstmtHold.clearParameters(); updCnt = pstmtHold.executeUpdate();
pstmtHold.clearParameters();
if( updCnt > 0 )
{ if( updCnt > 0 )
System.out.println( updCnt + " rows updated successfully" ); {
} System.out.println( updCnt + " rows updated successfully" );
}
HashMap dataMap = new HashMap();
HashMap dataMap = new HashMap();
for ( int ctr = 0; ctr < stockList.size(); ctr++ )
{ for ( int ctr = 0; ctr < stockList.size(); ctr++ )
lineNo++; {
dataMap = (HashMap)stockList.get(ctr); lineNo++;
dataMap = (HashMap)stockList.get(ctr);
itemCode = "";
siteCode = ""; itemCode = "";
locCode = ""; siteCode = "";
lotNo = ""; locCode = "";
lotSl = ""; lotNo = "";
lotSl = "";
if ( dataMap.get("item_code") != null )
{ if ( dataMap.get("item_code") != null )
itemCode = (String)dataMap.get("item_code"); {
} itemCode = (String)dataMap.get("item_code");
if ( dataMap.get("site_code") != null ) }
{ if ( dataMap.get("site_code") != null )
siteCode = (String)dataMap.get("site_code"); {
} siteCode = (String)dataMap.get("site_code");
if ( dataMap.get("loc_code") != null ) }
{ if ( dataMap.get("loc_code") != null )
locCode = (String)dataMap.get("loc_code"); {
} locCode = (String)dataMap.get("loc_code");
if ( dataMap.get("lot_no") != null ) }
{ if ( dataMap.get("lot_no") != null )
lotNo = (String)dataMap.get("lot_no"); {
} lotNo = (String)dataMap.get("lot_no");
if ( dataMap.get("lot_sl") != null ) }
{ if ( dataMap.get("lot_sl") != null )
lotSl = (String)dataMap.get("lot_sl"); {
} lotSl = (String)dataMap.get("lot_sl");
pstmtHolddet.setString( 1, tranId ); }
pstmtHolddet.setInt( 2, lineNo ); pstmtHolddet.setString( 1, tranId );
pstmtHolddet.setString( 3, itemCode ); pstmtHolddet.setInt( 2, lineNo );
pstmtHolddet.setString( 4, siteCode ); pstmtHolddet.setString( 3, itemCode );
pstmtHolddet.setString( 5, locCode ); pstmtHolddet.setString( 4, siteCode );
pstmtHolddet.setString( 6, lotNo ); pstmtHolddet.setString( 5, locCode );
pstmtHolddet.setString( 7, lotSl ); pstmtHolddet.setString( 6, lotNo );
pstmtHolddet.setString( 8, "H" ); pstmtHolddet.setString( 7, lotSl );
pstmtHolddet.addBatch(); pstmtHolddet.setString( 8, "H" );
pstmtHolddet.clearParameters(); pstmtHolddet.addBatch();
dataMap.clear(); pstmtHolddet.clearParameters();
} dataMap.clear();
pstmtHolddet.executeBatch(); }
pstmtHolddet.clearBatch(); pstmtHolddet.executeBatch();
} pstmtHolddet.clearBatch();
catch(BatchUpdateException buex) InvHoldConf invHoldConf = new InvHoldConf();
{ retString = invHoldConf.confirm( tranId, xtraParams, "" , conn ,false);
isError = true; if (retString.indexOf("VTCNFSUCC") > 0)
retString = "ERROR"; {
int [] updateCounts = buex.getUpdateCounts(); retString = "";
for (int i = 0; i < updateCounts.length; i++) }
{ else
System.err.println(" Statement " + i + ":" + updateCounts[i]); {
} isError = true;
System.err.println(" Message: " + buex.getMessage()); }
System.err.println(" SQLSTATE: " + buex.getSQLState()); }
System.err.println(" Error code: " + buex.getErrorCode()); catch(BatchUpdateException buex)
SQLException ex = buex.getNextException(); {
while (ex != null) isError = true;
{ retString = "ERROR";
System.err.println("SQL exception:"); int [] updateCounts = buex.getUpdateCounts();
System.err.println(" Message: " + ex.getMessage()); for (int i = 0; i < updateCounts.length; i++)
System.err.println(" SQLSTATE: " + ex.getSQLState()); {
System.err.println(" Error code: " + ex.getErrorCode()); System.err.println(" Statement " + i + ":" + updateCounts[i]);
ex = ex.getNextException(); }
} System.err.println(" Message: " + buex.getMessage());
} System.err.println(" SQLSTATE: " + buex.getSQLState());
catch (Exception e) System.err.println(" Error code: " + buex.getErrorCode());
{ SQLException ex = buex.getNextException();
isError = true; while (ex != null)
retString = "ERROR"; {
System.out.println ( "Exception: InvHoldGen: " + e.getMessage() + ":" ); System.err.println("SQL exception:");
throw new ITMException(e); System.err.println(" Message: " + ex.getMessage());
} System.err.println(" SQLSTATE: " + ex.getSQLState());
finally System.err.println(" Error code: " + ex.getErrorCode());
{ ex = ex.getNextException();
try }
{ }
if ( !isError ) catch (Exception e)
{ {
//conn.commit(); isError = true;
} retString = "ERROR";
if ( rsSel !=null ) System.out.println ( "Exception: InvHoldGen: " + e.getMessage() + ":" );
{ throw new ITMException(e);
rsSel.close(); }
rsSel = null; finally
} {
if ( pstmtHold!=null ) try
{ {
pstmtHold.close(); if ( !isError )
pstmtHold = null; {
} //conn.commit();
if ( pstmtHolddet!=null ) }
{ if ( rsSel !=null )
pstmtHolddet.close(); {
pstmtHolddet = null; rsSel.close();
} rsSel = null;
} }
catch(Exception e) if ( pstmtHold!=null )
{ {
System.out.println( "Exception ::==>\n"+e.getMessage()); pstmtHold.close();
throw new ITMException(e); pstmtHold = null;
} }
} if ( pstmtHolddet!=null )
return retString; {
} pstmtHolddet.close();
pstmtHolddet = null;
private String generateTranId( String windowName, Connection conn )throws ITMException }
{ }
PreparedStatement pstmt = null; catch(Exception e)
ResultSet rs = null; {
String selSql = ""; System.out.println( "Exception ::==>\n"+e.getMessage());
String tranId = ""; throw new ITMException(e);
String tranSer = ""; }
String keyString = ""; }
String keyCol = ""; return retString;
String xmlValues = ""; }
String paySiteCode = "";
String effectiveDate = ""; private String generateTranId( String windowName, Connection conn )throws ITMException
{
java.sql.Date effDate = null; PreparedStatement pstmt = null;
ResultSet rs = null;
try String selSql = "";
{ String tranId = "";
selSql = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE TRAN_WINDOW = ? "; String tranSer = "";
//System.out.println("selSql :"+selSql); String keyString = "";
pstmt = conn.prepareStatement(selSql); String keyCol = "";
pstmt.setString( 1, windowName ); String xmlValues = "";
rs = pstmt.executeQuery(); String paySiteCode = "";
if (rs.next()) String effectiveDate = "";
{
keyString = rs.getString("KEY_STRING"); java.sql.Date effDate = null;
keyCol = rs.getString("TRAN_ID_COL");
tranSer = rs.getString("REF_SER"); try
} {
rs.close();rs = null; selSql = "SELECT KEY_STRING, TRAN_ID_COL, REF_SER FROM TRANSETUP WHERE TRAN_WINDOW = ? ";
pstmt.close();pstmt = null; //System.out.println("selSql :"+selSql);
System.out.println("keyString :"+keyString); pstmt = conn.prepareStatement(selSql);
System.out.println("keyCol :"+keyCol); pstmt.setString( 1, windowName );
System.out.println("tranSer :"+tranSer); rs = pstmt.executeQuery();
if (rs.next())
xmlValues ="<?xml version=\"1.0\" encoding=\"utf-8\"?><Root>"; {
xmlValues = xmlValues + "<Header></Header>"; keyString = rs.getString("KEY_STRING");
xmlValues = xmlValues + "<Detail1>"; keyCol = rs.getString("TRAN_ID_COL");
xmlValues = xmlValues + "<tran_id></tran_id>"; tranSer = rs.getString("REF_SER");
xmlValues = xmlValues + "</Detail1></Root>"; }
System.out.println("xmlValues :["+xmlValues+"]"); rs.close();rs = null;
TransIDGenerator tg = new TransIDGenerator(xmlValues, "BASE", CommonConstants.DB_NAME); pstmt.close();pstmt = null;
tranId = tg.generateTranSeqID(tranSer, keyCol, keyString, conn); System.out.println("keyString :"+keyString);
System.out.println("tranId :"+tranId); System.out.println("keyCol :"+keyCol);
} System.out.println("tranSer :"+tranSer);
catch (SQLException ex)
{ xmlValues ="<?xml version=\"1.0\" encoding=\"utf-8\"?><Root>";
System.out.println("Exception ::" +selSql+ ex.getMessage() + ":"); xmlValues = xmlValues + "<Header></Header>";
ex.printStackTrace(); xmlValues = xmlValues + "<Detail1>";
throw new ITMException(ex); xmlValues = xmlValues + "<tran_id></tran_id>";
} xmlValues = xmlValues + "</Detail1></Root>";
catch (Exception e) System.out.println("xmlValues :["+xmlValues+"]");
{ TransIDGenerator tg = new TransIDGenerator(xmlValues, "BASE", CommonConstants.DB_NAME);
System.out.println("Exception ::" + e.getMessage() + ":"); tranId = tg.generateTranSeqID(tranSer, keyCol, keyString, conn);
e.printStackTrace(); System.out.println("tranId :"+tranId);
throw new ITMException(e); }
} catch (SQLException ex)
finally {
{ System.out.println("Exception ::" +selSql+ ex.getMessage() + ":");
try ex.printStackTrace();
{ throw new ITMException(ex);
if (rs != null) }
{ catch (Exception e)
rs.close(); {
rs = null; System.out.println("Exception ::" + e.getMessage() + ":");
} e.printStackTrace();
if (pstmt != null) throw new ITMException(e);
{ }
pstmt.close(); finally
pstmt = null; {
} try
} {
catch(Exception e){} if (rs != null)
} {
return tranId; rs.close();
}//generateTranTd() rs = null;
} }
if (pstmt != null)
{
pstmt.close();
pstmt = null;
}
}
catch(Exception e){}
}
return tranId;
}//generateTranTd()
}
webitm-dis/ibase/webitm/ejb/dis/adv/PoRcpConf.java
View file @ abaf44e2
...@@ -1164,18 +1164,18 @@ public class PoRcpConf extends ActionHandlerEJB implements PoRcpConfLocal, PoRcp ...@@ -1164,18 +1164,18 @@ public class PoRcpConf extends ActionHandlerEJB implements PoRcpConfLocal, PoRcp
itemLockList = new ArrayList(); itemLockList = new ArrayList();
sql = "select lock_code from lock_group " sql = "select lock_code from lock_group "
+ " where lock_group = ? " ; + " where lock_group = ? " ;
pstmt = conn.prepareStatement(sql); pstmt1 = conn.prepareStatement(sql);
pstmt.setString(1, tempLockGroup); pstmt1.setString(1, tempLockGroup);
rs = pstmt.executeQuery(); rs1 = pstmt1.executeQuery();
while ( rs.next() ) while ( rs1.next() )
{ {
lockCode = rs.getString("lock_code"); lockCode = rs1.getString("lock_code");
itemLockList.add(lockCode); itemLockList.add(lockCode);
} }
pstmt.close(); pstmt1.close();
pstmt = null; pstmt1 = null;
rs.close(); rs1.close();
rs = null; rs1 = null;
} }
else if(suppLockList.size() > 0) else if(suppLockList.size() > 0)
......
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