Skip to content

B
business-java
Commit 539d5e8f authored by prane's avatar prane
Browse files
Options

All statement to be converted to prepared statement and closing 

git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@199625 ce508802-f39f-4f6c-b175-0d175dae99d5
parent 08171776
Hide whitespace changes
Inline Side-by-side
Showing with 799 additions and 272 deletions
webitm-dis/ibase/webitm/ejb/dis/adv/AdjIssAct.java
View file @ 539d5e8f
......@@ -125,9 +125,10 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
private String actionStock(Document dom,Document dom1, String objContext, String xtraParams) throws RemoteException , ITMException
{
Connection conn = null;
Statement stmt = null;
//Statement stmt = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
ResultSet rs1 = null;
//ResultSet rs1 = null;
String sql = "";
String errCode = "";
String siteCode = "";
......@@ -153,7 +154,7 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
return valueXmlString.toString();
}
ibase.utility.E12GenericUtility genericUtility= new ibase.utility.E12GenericUtility();
ConnDriver connDriver = new ConnDriver();
//ConnDriver connDriver = new ConnDriver();
try
{
//Changes and Commented By Bhushan on 09-06-2016 :START
......@@ -161,7 +162,7 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
// stmt = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE); //Gulzar 18/03/07 - As Not working in DB2 and gives Exception like - sensitive cursor cannot be defined for the specified select statement
stmt = conn.createStatement(); //Gulzar 18/03/07
//stmt = conn.createStatement(); //Gulzar 18/03/07
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
siteCode = genericUtility.getColumnValue("site_code",dom1);
......@@ -175,16 +176,22 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
//sql=" SELECT COUNT(A.ITEM_CODE) FROM STOCK A, INVSTAT B "+
sql=" SELECT COUNT(*) FROM STOCK A, INVSTAT B "+
" WHERE A.INV_STAT = B.INV_STAT AND A.ITEM_CODE ='"+itemCode+"'"+
" AND A.SITE_CODE ='"+siteCode+"'"+
" WHERE A.INV_STAT = B.INV_STAT AND A.ITEM_CODE = ? " +//'"+itemCode+"'"+
" AND A.SITE_CODE = ? " +//'"+siteCode+"'"+
" AND (CASE WHEN ((CASE WHEN A.QUANTITY IS NULL THEN 0 ELSE A.QUANTITY END) - (CASE WHEN A.ALLOC_QTY IS NULL THEN 0 ELSE A.ALLOC_QTY END)) "+
" IS NULL THEN 0 ELSE ((CASE WHEN A.QUANTITY IS NULL THEN 0 ELSE A.QUANTITY END) - (CASE WHEN A.ALLOC_QTY IS NULL THEN 0 ELSE A.ALLOC_QTY END)) END ) > 0 ";
System.out.println("sql:"+sql);
rs = stmt.executeQuery(sql);
//System.out.println("sql:"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
pstmt.setString(2, siteCode);
rs = pstmt.executeQuery();
if(rs.next())
{
row = rs.getInt(1);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
System.out.println("row:"+row);
if(row > 0)
{
......@@ -223,8 +230,10 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
sql = sql + "( STOCK.QUANTITY - STOCK.ALLOC_QTY > 0 ) " +
" ORDER BY (CASE WHEN STOCK.EXP_DATE IS NULL THEN STOCK.CREA_DATE ELSE STOCK.EXP_DATE end) ASC, STOCK.LOT_NO ASC, " +
" STOCK.LOT_SL ASC ";
System.out.println("AdjIss:actionStock:sql:"+sql);
rs = stmt.executeQuery(sql);
//System.out.println("AdjIss:actionStock:sql:"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
while(rs.next())
{
itemSer = rs.getString(1);
......@@ -315,6 +324,8 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
valueXmlString.append("</Detail>\r\n");
}//end while
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
valueXmlString.append("</Root>\r\n");
}
......@@ -331,8 +342,15 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
finally
{
try{
conn.close();
conn = null;
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(conn != null) {
conn.close(); conn = null;
}
}catch(Exception e){}
}
System.out.println("valueXmlString.toString() "+valueXmlString.toString());
......@@ -355,7 +373,8 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDbAccess = new ITMDBAccessEJB(); //Added by Alka on 31/05/2007
Connection conn = null;
Statement stmt = null;
//Statement stmt = null;
PreparedStatement pstmt = null;
ResultSet rs = null;
try
{
......@@ -363,7 +382,7 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
stmt = conn.createStatement();
//stmt = conn.createStatement();
userId = new ibase.utility.E12GenericUtility().getValueFromXTRA_PARAMS(xtraParams, "loginCode");//Added by Alka on 31/05/2007
tranId = new ibase.utility.E12GenericUtility().getColumnValue("tran_id",dom1);
......@@ -399,12 +418,17 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
}
// end Added by Alka 31/05/07
sql = "SELECT ISS_CRITERIA FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
rs = stmt.executeQuery(sql);
sql = "SELECT ISS_CRITERIA FROM ITEM WHERE ITEM_CODE = ?"; //'"+itemCode+"'";
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
issCriteria = rs.getString("ISS_CRITERIA");
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
detailList = selDataDom.getElementsByTagName("Detail");
detailListLength = detailList.getLength();
for (int i = 0;i < detailListLength;i++ )
......@@ -552,8 +576,19 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
{
try
{
conn.close();
conn = null;
if(rs != null)
{
rs.close(); rs = null;
}
if(pstmt != null)
{
pstmt.close(); pstmt = null;
}
if(conn != null)
{
conn.close();
conn = null;
}
}
catch (Exception se){}
}
......@@ -577,7 +612,7 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
return valueXmlString.toString();
}
ibase.utility.E12GenericUtility genericUtility= new ibase.utility.E12GenericUtility();
ConnDriver connDriver = new ConnDriver();
//ConnDriver connDriver = new ConnDriver();
try
{
//Changes and Commented By Bhushan on 09-06-2016 :START
......@@ -590,7 +625,7 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
sql = " SELECT LOC_CODE, DESCR FROM LOCATION";
System.out.println("AdjIssDamage:actionStock:sql:"+sql);
//System.out.println("AdjIssDamage:actionStock:sql:"+sql);
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
while(rs.next())
......@@ -602,8 +637,8 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
valueXmlString.append("<loc_descr>").append("<![CDATA[").append(locDescr.trim()).append("]]>").append("</loc_descr>\r\n");
valueXmlString.append("</Detail>\r\n");
}//end while
rs.close();
pstmt.close();
rs.close(); rs = null;
pstmt.close(); pstmt = null;
valueXmlString.append("</Root>\r\n");
}
catch(SQLException e)
......@@ -619,8 +654,19 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
finally
{
try{
conn.close();
conn = null;
if(rs != null) {
rs.close();
rs = null;
}
if(pstmt != null) {
pstmt.close();
pstmt = null;
}
if(conn != null) {
conn.close();
conn = null;
}
}catch(Exception e){}
}
System.out.println("valueXmlString.toString() "+valueXmlString.toString());
......@@ -667,7 +713,7 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
+ " (CASE WHEN A.ALLOC_QTY IS NULL THEN 0 ELSE A.ALLOC_QTY END) > 0) "
+ " ORDER BY (CASE WHEN A.EXP_DATE IS NULL THEN A.CREA_DATE ELSE A.EXP_DATE END) ASC, "
+ " A.LOT_NO ASC, A.LOT_SL ASC";
System.out.println("sql ::: "+ sql);
//System.out.println("sql ::: "+ sql);
System.out.println("Setting siteCode ::: "+ siteCode +" -- selLocCode :: " + selLocCode);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCode);
......@@ -700,7 +746,7 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
sql = "SELECT UDF_STR1 FROM GENCODES WHERE FLD_NAME = 'REAS_CODE' AND (MOD_NAME = 'W_ADJ_ISS' OR MOD_NAME = 'X')"
+ " AND RTRIM(FLD_VALUE) = ?";
pstmt1 = conn.prepareStatement(sql);
System.out.println("sql ::: " + sql);
//System.out.println("sql ::: " + sql);
System.out.println("reasCode ::: "+ reasCode);
pstmt1.setString(1, reasCode);
rs1 = pstmt1.executeQuery();
......@@ -714,8 +760,8 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
acctCodeDr = "";
cctrCodeDr = "";
}
rs1.close();
pstmt1.close();
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
if (udfStr != null && udfStr.trim().length() > 0)
{
acctCodeDr = udfStr.substring(0,udfStr.indexOf(","));
......@@ -726,6 +772,8 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
valueXmlString.append("</Detail>");
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
valueXmlString.append("</Root>\r\n");
}
......@@ -739,10 +787,22 @@ public class AdjIssAct extends ActionHandlerEJB implements AdjIssActLocal, AdjIs
{
try
{
if(rs != null) {
rs.close(); rs = null;
pstmt.close(); pstmt = null;
conn.close();
conn = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(rs1 != null) {
rs1.close(); rs1 = null;
}
if(pstmt1 != null) {
pstmt1.close(); pstmt1 = null;
}
if(conn != null) {
conn.close();
conn = null;
}
}
catch (Exception se){}
}
......
webitm-dis/ibase/webitm/ejb/dis/adv/DistIssueAct.java
View file @ 539d5e8f
......@@ -4,7 +4,7 @@ import ibase.webitm.utility.ITMException;
import ibase.webitm.ejb.*;
import ibase.utility.E12GenericUtility;
import ibase.system.config.*;
//import ibase.system.config.*;
import ibase.utility.CommonConstants;
import java.rmi.RemoteException;
......@@ -13,7 +13,7 @@ import java.sql.*;
import java.text.NumberFormat;//added by nisar on 11/23/2007
import org.w3c.dom.*;
import javax.ejb.*;
import javax.naming.InitialContext;
//import javax.naming.InitialContext;
import java.io.*;
import java.text.SimpleDateFormat;
......@@ -177,10 +177,11 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
String sql = "";
ResultSet rs = null;
Connection conn = null;
Statement stmt = null;
//Statement stmt = null;
PreparedStatement pstmt = null;
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n");
//ibase.utility.E12GenericUtility genericUtility= new ibase.utility.E12GenericUtility();
ConnDriver connDriver = new ConnDriver();
//ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
try
{
......@@ -188,7 +189,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
stmt = conn.createStatement();
//stmt = conn.createStatement();
//String detailDom= genericUtility.serializeDom(dom);
//System.out.println("detailDomlist::::"+detailDom);
......@@ -209,13 +210,18 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
locCode = locCode.trim() + "%";
}
sql ="SELECT CASE WHEN TRACK_SHELF_LIFE IS NULL THEN 'N' ELSE TRACK_SHELF_LIFE END "
+"FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
+"FROM ITEM WHERE ITEM_CODE = ?"; //'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
tracShelfLife = rs.getString(1);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (tracShelfLife.equals("N"))
{
sql = "SELECT STOCK.ITEM_CODE, "
......@@ -261,12 +267,14 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+"AND INVSTAT.STAT_TYPE = 'M' "
+"ORDER BY STOCK.EXP_DATE ASC";
}
System.out.println("sql :"+sql);
stmt.close();
stmt = null;
stmt = conn.createStatement();
rs = stmt.executeQuery(sql);
//System.out.println("sql :"+sql);
//stmt.close();
//stmt = null;
//stmt = conn.createStatement();
//rs = stmt.executeQuery(sql);
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
while (rs.next())
{
mfgDate1 = "";
......@@ -328,8 +336,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
//Add by Ajay on 02/05/18:START
rs.close();
rs = null;
stmt.close();
stmt = null;
pstmt.close();
pstmt = null;
//Add by Ajay on 02/05/18:END
//while end
}
......@@ -345,8 +353,22 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
System.out.println("Closing Connection.....");
conn.close();
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(conn != null)
{
System.out.println("Closing Connection.....");
conn.close();
conn = null;
}
}catch(Exception e){}
}
System.out.println("valueXmlString.toString() "+valueXmlString.toString());
......@@ -363,9 +385,9 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
Node currDetail = null;
int detailListLength = 0,noArt1 = 0, noArt2 = 0;
Connection conn = null;
Statement stmt = null;
//Statement stmt = null;
ResultSet rs = null, rs1 = null;
ConnDriver connDriver = new ConnDriver();
//ConnDriver connDriver = new ConnDriver();
double ordQty = 0,pickQty = 0,integralQty = 0, stkQty = 0, remainingQty = 0, rate1 = 0, rateClg = 0, convQtyAlt = 0;
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n");
//ibase.utility.E12GenericUtility genericUtility= new ibase.utility.E12GenericUtility(); //ADDED BY ALKA ON 24/07/07
......@@ -384,7 +406,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
stmt = conn.createStatement();
//stmt = conn.createStatement();
if (qtyStr.equals("0"))
{
qtyStr = genericUtility.getColumnValue("quantity",dom);
......@@ -439,12 +461,17 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
if (tranType != null && tranType.trim().length() > 0)
{
sql = "SELECT CHECK_INTEGRAL_QTY FROM DISTORDER_TYPE WHERE TRAN_TYPE = '"+tranType+"'";
rs = stmt.executeQuery(sql);
sql = "SELECT CHECK_INTEGRAL_QTY FROM DISTORDER_TYPE WHERE TRAN_TYPE = ? ";//'"+tranType+"'";
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranType);
rs = pstmt.executeQuery();
if (rs.next())
{
checkIntegralQty = rs.getString(1);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (checkIntegralQty == null || checkIntegralQty.equals(""))
{
checkIntegralQty = "Y";
......@@ -552,10 +579,10 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
priceListClg = rs.getString("PRICE_LIST__CLG");
sundryCode = rs.getString("SUNDRY_CODE");
}
pstmt.close();
pstmt = null;
rs.close();
rs = null;
pstmt.close();
pstmt = null;
sql ="select (case when shipper_size is null then 0 else shipper_size end) shipper_size"
+" from item_lot_packsize where item_code = ? "
......@@ -570,10 +597,10 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
shipperSize = rs1.getDouble(1);
}
pstmt.close();
pstmt = null;
rs1.close();
rs1 = null;
pstmt.close();
pstmt = null;
if( shipperSize > 0)
{
......@@ -591,10 +618,10 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
integralqty = rs1.getDouble(1);
}
pstmt.close();
pstmt = null;
rs1.close();
rs1 = null;
pstmt.close();
pstmt = null;
//System.out.println("integralqty .............:"+integralqty);
if(integralqty ==0)
{
......@@ -609,10 +636,10 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
integralqty = rs1.getDouble(1);
}
pstmt.close();
pstmt = null;
rs1.close();
rs1 = null;
pstmt.close();
pstmt = null;
if(integralqty ==0)
{
......@@ -625,10 +652,10 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
integralqty = rs1.getDouble(1);
}
pstmt.close();
pstmt = null;
rs1.close();
rs1 = null;
pstmt.close();
pstmt = null;
}
}
......@@ -669,10 +696,10 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
rate1 = rs.getDouble("RATE");
rateClg = rs.getDouble("RATE__CLG");
}
pstmt.close();
pstmt = null;
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if (rate1 == 0)
{
type = Character.toString( priceListType(priceList) );
......@@ -775,6 +802,16 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
if(rs != null) {
rs.close(); rs = null;
}
if(rs1 != null) {
rs1.close(); rs1 = null;
}
if(pstmt != null){
pstmt.close(); pstmt = null;
}
if(conn != null)
{
conn.close();
......@@ -823,7 +860,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
boolean flag = true;
StringBuffer valueXmlString = new StringBuffer("<?xml version='1.0' encoding='"+commonConstants.ENCODING+"'?> \r\n<Root>\r\n");
//ibase.utility.E12GenericUtility genericUtility= new ibase.utility.E12GenericUtility();
ConnDriver connDriver = new ConnDriver();
//ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
/* String grossWeight = "";
String tareWeight = "";
......@@ -931,8 +968,20 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
System.out.println("Closing Connection.....");
conn.close();
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null){
pstmt.close(); pstmt = null;
}
if(conn != null)
{
System.out.println("Closing Connection.....");
conn.close();
conn = null;
}
//conn.close();
}catch(Exception e){}
}
System.out.println("valueXmlString.toString() "+valueXmlString.toString());
......@@ -953,7 +1002,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
Connection conn = null;
PreparedStatement pstmt = null, pstmt1 = null;
ResultSet rs = null, rs1 = null;
ConnDriver connDriver = new ConnDriver();
//ConnDriver connDriver = new ConnDriver();
double ordQty = 0,pickQty = 0,integralQty = 0, stkQty = 0, remainingQty = 0, rate = 0, amount = 0, netAmt = 0, taxAmt = 0, potencyPerc = 0;
double palletWt = 0,palletWt1 = 0 ;//added by kunal on 06/02/12
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n");
......@@ -1364,10 +1413,26 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
if(conn != null)
{
conn.close();
conn = null;
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(rs1 != null) {
rs1.close(); rs1 = null;
}
if(pstmt1 != null) {
pstmt1.close(); pstmt1 = null;
}
if(rs2 != null) {
rs2.close(); rs2 = null;
}
if(pstmt2 != null) {
pstmt2.close(); pstmt2 = null;
}
if(conn != null) {
conn.close(); conn = null;
}
}
catch( Exception e )
......@@ -1391,11 +1456,13 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
String detailCnt = "0";
ResultSet rs = null;
Connection conn = null;
Statement stmt = null;
//Statement stmt = null;
PreparedStatement pstmt = null;
String tranDate = "", distIssue = "";
String sql1 = "", sql2 = "", sql3 = "";
ResultSet rs1 = null, rs2 = null, rs3 = null;
Statement stmt1 = null, stmt2 = null, stmt3 = null;
//Statement stmt1 = null, stmt2 = null, stmt3 = null;
PreparedStatement pstmt1 = null;
String taxClass = "", taxChap = "", taxEnv = "";
String priceList = "", siteCodeMfg = "";
String mfgDate1 = "", expDate1 = "", retestDate1 = "";
......@@ -1412,7 +1479,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
boolean flag = true;
StringBuffer valueXmlString = new StringBuffer("<?xml version=\"1.0\"?>\r\n<Root>\r\n");
//ibase.utility.E12GenericUtility genericUtility= new ibase.utility.E12GenericUtility();
ConnDriver connDriver = new ConnDriver();
//ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
/* String grossWeight = "";
String tareWeight = "";
......@@ -1428,7 +1495,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
stmt = conn.createStatement();
//stmt = conn.createStatement();
distOrder = genericUtility.getColumnValue("dist_order",dom1);
System.out.println("distOrder :"+distOrder);
/*Commented for cross update need to entry in obj_forms
......@@ -1436,14 +1503,20 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
tareWeight = genericUtility.getColumnValue("tare_weight",dom1);
netWeight = genericUtility.getColumnValue("net_weight",dom1);
*/
sql = "SELECT COUNT(*) FROM INV_PACK WHERE ORDER_NO = '"+distOrder+"' "+"AND ORDER_TYPE = 'D' ";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
//sql = "SELECT COUNT(*) FROM INV_PACK WHERE ORDER_NO = '"+distOrder+"' "+"AND ORDER_TYPE = 'D' ";
sql = "SELECT COUNT(*) FROM INV_PACK WHERE ORDER_NO = ? AND ORDER_TYPE = 'D' ";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, distOrder);
rs = pstmt.executeQuery();
if (rs.next())
{
count = rs.getInt(1);
System.out.println("Count :"+count);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (count == 0)
{
errCode = "VTCNTNLL";
......@@ -1453,47 +1526,66 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else if (count == 1)
{
sql = "SELECT TRAN_ID,SITE_CODE FROM INV_PACK WHERE ORDER_NO = '"+distOrder+"' "
sql = "SELECT TRAN_ID,SITE_CODE FROM INV_PACK WHERE ORDER_NO = ? " //'"+distOrder+"' "
+" AND ORDER_TYPE = 'D'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, distOrder);
rs = pstmt.executeQuery();
if (rs.next())
{
tranId = rs.getString(1);
siteCode = rs.getString(2);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
else if (count > 1)//To be asked to Piyush Sir as it opens window for selecting a specific record.
{
sql = "SELECT INV_PACK.TRAN_ID, INV_PACK.TRAN_DATE, INV_PACK.ORDER_NO, INV_PACK.SITE_CODE "
+"FROM INV_PACK WHERE INV_PACK.ORDER_NO = '"+distOrder+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
+"FROM INV_PACK WHERE INV_PACK.ORDER_NO = ? "; //'"+distOrder+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, distOrder);
rs = pstmt.executeQuery();
if (rs.next())
{
tranId = rs.getString(1); // to be ask to piyush sir about multiple records selection
System.out.println("tranId :"+tranId);
}
sql = "SELECT SITE_CODE FROM INV_PACK WHERE TRAN_ID = '"+tranId+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
rs.close(); rs = null;
pstmt.close(); pstmt = null;
sql = "SELECT SITE_CODE FROM INV_PACK WHERE TRAN_ID = ? "; //'"+tranId+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
if (rs.next())
{
siteCode = rs.getString(1);
System.out.println("siteCode :"+siteCode);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
tranDate = genericUtility.getColumnValue("tran_date",dom1);
distIssue = genericUtility.getColumnValue("tran_id",dom1);
sql = "SELECT LINE_NO__ORD, ITEM_CODE, LOT_NO, LOT_SL, QUANTITY,UNIT, PACK_CODE, "
+"PACK_INSTR,LOC_CODE,GROSS_WEIGHT, TARE_WEIGHT, NET_WEIGHT, DIMENSION, NO_ART "
+"FROM INV_PACK_RCP "
+"WHERE TRAN_ID = '"+tranId+"'"+" ORDER BY LINE_NO__ORD";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
stmt1 = conn.createStatement();
//+"WHERE TRAN_ID = '"+tranId+"'"+" ORDER BY LINE_NO__ORD";
+"WHERE TRAN_ID = ? ORDER BY LINE_NO__ORD";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, tranId);
rs = pstmt.executeQuery();
/*stmt1 = conn.createStatement();
stmt2 = conn.createStatement();
stmt3 = conn.createStatement();
stmt3 = conn.createStatement();*/
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
while (rs.next())
{
......@@ -1504,9 +1596,14 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
valueXmlString.append("<line_no_dist_order>").append("<![CDATA[").append(rs.getString(1).trim()).append("]]>").append("</line_no_dist_order>\r\n");
sql1 = "SELECT TAX_CLASS, TAX_CHAP, TAX_ENV, CASE WHEN RATE IS NULL THEN 0 ELSE RATE END "
+"FROM DISTORDER_DET WHERE DIST_ORDER = '"+distOrder+"'"+" AND LINE_NO = '"+rs.getString(1)+"'";
System.out.println("sql1 :"+sql1);
rs1 = stmt1.executeQuery(sql1);
//+"FROM DISTORDER_DET WHERE DIST_ORDER = '"+distOrder+"'"+" AND LINE_NO = '"+rs.getString(1)+"'";
+"FROM DISTORDER_DET WHERE DIST_ORDER = ? AND LINE_NO = ? ";
//System.out.println("sql1 :"+sql1);
//rs1 = stmt1.executeQuery(sql1);
pstmt1 = conn.prepareStatement(sql1);
pstmt1.setString(1, distOrder);
pstmt1.setString(2, rs.getString(1));
rs1 = pstmt1.executeQuery();
if (rs1.next())
{
taxClass = rs1.getString(1);
......@@ -1514,6 +1611,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
taxEnv = rs1.getString(3);
rate = rs1.getDouble(4);
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
valueXmlString.append("<item_code>").append("<![CDATA[").append(rs.getString(2).trim()).append("]]>").append("</item_code>\r\n");
valueXmlString.append("<quantity isSrvCallOnChg='1'>").append("<![CDATA[").append(rs.getString(5).trim()).append("]]>").append("</quantity>\r\n");
valueXmlString.append("<unit>").append("<![CDATA[").append(rs.getString(6).trim()).append("]]>").append("</unit>\r\n");
......@@ -1521,14 +1620,19 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
if (rate == 0)
{
sql2 = "SELECT PRICE_LIST FROM DISTORDER WHERE DIST_ORDER = '"+distOrder+"'";
System.out.println("sql2 :"+sql2);
rs2 = stmt2.executeQuery(sql2);
if (rs2.next())
sql2 = "SELECT PRICE_LIST FROM DISTORDER WHERE DIST_ORDER = ? " ;//'"+distOrder+"'";
//System.out.println("sql2 :"+sql2);
//rs2 = stmt2.executeQuery(sql2);
pstmt1 = conn.prepareStatement(sql2);
pstmt1.setString(1, distOrder);
rs1 = pstmt1.executeQuery();
if (rs1.next())
{
priceList = rs2.getString(1);
priceList = rs1.getString(1);
System.out.println("priceList :"+priceList);
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
//Calls nvo_business_object_dist gbf_pick_rate() method i.e. converted below as pickRate() method
rate = pickRate(priceList, tranDate, rs.getString("ITEM_CODE"), rs.getString("LOT_NO"),'D');
}
......@@ -1583,17 +1687,22 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+"AND LOC_CODE = '"+rs.getString(9)+"' "
+"AND LOT_NO = '"+rs.getString(3)+"' "
+"AND LOT_SL = '"+rs.getString(4)+"' ";
rs3 = stmt3.executeQuery(sql3);
if (rs3.next())
//rs3 = stmt3.executeQuery(sql3);
pstmt1 = conn.prepareStatement(sql3);
pstmt1.setString(1, distOrder);
rs1 = pstmt1.executeQuery();
if (rs1.next())
{
siteCodeMfg = rs3.getString(1);
mfgDate = rs3.getDate(2);
expDate = rs3.getDate(3);
potencyPerc = rs3.getDouble(4);
batchNo = rs3.getString(5);
grade = rs3.getString(6);
retestDate = rs3.getDate(7);
siteCodeMfg = rs1.getString(1);
mfgDate = rs1.getDate(2);
expDate = rs1.getDate(3);
potencyPerc = rs1.getDouble(4);
batchNo = rs1.getString(5);
grade = rs1.getString(6);
retestDate = rs1.getDate(7);
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
if (mfgDate != null)
{
mfgDate1 = sdf.format(mfgDate);
......@@ -1628,6 +1737,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
cnt++;
}//end while
rs.close(); rs = null;
pstmt.close(); pstmt = null;
valueXmlString.append("</Root>\r\n");
if (cnt == 0)
{
......@@ -1648,8 +1759,23 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
System.out.println("Closing Connection.....");
conn.close();
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(rs1 != null) {
rs1.close(); rs1 = null;
}
if(pstmt1 != null) {
pstmt1.close(); pstmt1 = null;
}
if(conn != null) {
System.out.println("Closing Connection.....");
conn.close(); conn = null;
}
//conn.close();
}catch(Exception e){}
}
System.out.println("valueXmlString.toString() "+valueXmlString.toString());
......@@ -1669,11 +1795,11 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
String suppSour = "", trackShelfLife = "", siteCodeMfg = "", sundryCode = "", potencyPerc = "";
String priceList = "", tabValue = "", priceListClg = "", chkDate = "", disCountPer = "",issCriteria="";
String tranTypePparent = null;
Statement stmtS = null;
//Statement stmtS = null;
ResultSet rs = null, rs1 = null, rs2 = null, rsS = null;
Connection conn1 = null;
Statement stmt = null, stmt1 = null, stmt2 = null ;
PreparedStatement pstmt = null;
//Statement stmt = null, stmt1 = null, stmt2 = null ;
PreparedStatement pstmt = null, pstmt1 = null, pstmt2 = null;
double mod = 0d, minputQty = 0d, remQuantity = 0d, stockQty = 0d, integralQty = 0d;
double grossPer = 0d,netPer = 0d,tarePer = 0d, grossWt = 0d, netWt = 0d, tareWt =0d, rateClgVal = 0d, rate2 = 0d;
double disAmount = 0d, amount = 0d, shipperQty = 0d;
......@@ -1685,7 +1811,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
//changed by msalam on 22/09/07 and declared as class level
//ibase.utility.E12GenericUtility genericUtility= new ibase.utility.E12GenericUtility();
String tranTypeParent = null;
ConnDriver connDriver = new ConnDriver();
//ConnDriver connDriver = new ConnDriver();
ITMDBAccessEJB itmDBAccessEJB = new ITMDBAccessEJB();
try
......@@ -1697,10 +1823,10 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
//conn1 = connDriver.getConnectDB("DriverITM");
conn1 = getConnection();
//Changes and Commented By Bhushan on 13-06-2016 :END
stmt = conn1.createStatement();
/*stmt = conn1.createStatement();
stmt1 = conn1.createStatement();
stmt2 = conn1.createStatement();
stmtS = conn1.createStatement();
stmtS = conn1.createStatement();*/
SimpleDateFormat sdf = new SimpleDateFormat(genericUtility.getApplDateFormat());
availableYn = genericUtility.getColumnValue("available_yn",dom1);
......@@ -1805,9 +1931,12 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
if (tranType != null && tranType.trim().length() > 0)
{
sql = "SELECT CHECK_INTEGRAL_QTY, TRAN_TYPE__PARENT FROM DISTORDER_TYPE WHERE TRAN_TYPE ='" + tranType + "'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
sql = "SELECT CHECK_INTEGRAL_QTY, TRAN_TYPE__PARENT FROM DISTORDER_TYPE WHERE TRAN_TYPE = ? "; //'" + tranType + "'";
/*System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);*/
pstmt = conn1.prepareStatement(sql);
pstmt.setString(1, tranType);
rs = pstmt.executeQuery();
if (rs.next())
{
//System.out.println( "CHECK_INTEGRAL_QTY :" + rs.getString( 1 ) );
......@@ -1820,6 +1949,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
checkIntegralQty = "Y";
}
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
else
{
......@@ -1923,9 +2054,12 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
sql = " SELECT (CASE WHEN ACTIVE IS NULL THEN 'Y' ELSE ACTIVE END) ACT, MIN_SHELF_LIFE, "
+ " (CASE WHEN TRACK_SHELF_LIFE IS NULL THEN 'N' ELSE TRACK_SHELF_LIFE END) TRK_SHELF_LIFE, "
+ " (CASE WHEN SUPP_SOUR IS NULL THEN 'M' ELSE SUPP_SOUR END) SUP_SOUR, DESCR, ISS_CRITERIA "
+ " FROM ITEM WHERE ITEM_CODE = '" + itemCode + "'";
System.out.println( "sql :" + sql );
rs = stmt.executeQuery(sql);
+ " FROM ITEM WHERE ITEM_CODE = ? "; //'" + itemCode + "'";
//System.out.println( "sql :" + sql );
//rs = stmt.executeQuery(sql);
pstmt = conn1.prepareStatement(sql);
pstmt.setString(1, itemCode);
rs = pstmt.executeQuery();
if ( rs.next() )
{
active = rs.getString( 1 );
......@@ -1950,6 +2084,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
if( active.equals("N") )
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
errCode = "VTITEM4";
errString = itmDBAccessEJB.getErrorString("", errCode, "", "", conn1);
return errString;
......@@ -1959,8 +2095,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
rs.close();
rs = null;
stmt.close();
stmt = null;
pstmt.close();
pstmt = null;
//End To be optimized by msalam
//
......@@ -1970,12 +2106,15 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
//bring all DISTORDER attributes in one query
sql = " SELECT LOC_CODE__DAMAGED, SUNDRY_CODE, PRICE_LIST, PRICE_LIST__CLG "
+ " FROM DISTORDER WHERE DIST_ORDER = '" + distOrder + "'";
+ " FROM DISTORDER WHERE DIST_ORDER = ? "; //'" + distOrder + "'";
System.out.println("sql :"+sql);
stmt = conn1.createStatement();
rs = stmt.executeQuery(sql);
//System.out.println("sql :"+sql);
//stmt = conn1.createStatement();
//rs = stmt.executeQuery(sql);
pstmt = conn1.prepareStatement(sql);
pstmt.setString(1, distOrder);
rs = pstmt.executeQuery();
if (rs.next())
{
locCodeDamaged = rs.getString("LOC_CODE__DAMAGED");
......@@ -2009,8 +2148,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
rs.close();
rs = null;
stmt.close();
stmt = null;
pstmt.close();
pstmt = null;
//changed by msalam on 21/09/07 end
//End Add Gulzar 01/03/07
......@@ -2144,9 +2283,11 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
//End Add gulzar 01/03/07
sql = sql + " ORDER BY A.EXP_DATE,A.CREA_DATE,A.LOT_NO, A.LOT_SL ";
System.out.println( "sql :" + sql );
/*System.out.println( "sql :" + sql );
stmt = conn1.createStatement();
rs = stmt.executeQuery( sql );
rs = stmt.executeQuery( sql );*/
pstmt = conn1.prepareStatement(sql);
rs = pstmt.executeQuery();
remQuantity = Double.parseDouble(quantity);
//System.out.println("remQuantity :" + remQuantity);
while (rs.next())
......@@ -2292,11 +2433,15 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
sql2 = "SELECT COUNT(*) FROM PRICELIST "
+ "WHERE PRICE_LIST = '" + priceList + "'" + " AND LIST_TYPE = 'I' ";
//System.out.println("sql2 :" + sql2);
rs2 = stmt2.executeQuery(sql2);
//rs2 = stmt2.executeQuery(sql2);
pstmt2 = conn1.prepareStatement(sql2);
rs2 = pstmt2.executeQuery();
if (rs2.next())
{
count = rs2.getInt(1);
}
}
rs2.close(); rs2 = null;
pstmt2.close(); pstmt2 = null;
System.out.println("count :" + count);
if (count == 0)
{
......@@ -2454,12 +2599,16 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+" from item_lot_packsize where item_code = '"+itemCode+"'"
+" and '"+lotNo+"' >= lot_no__from "
+" and '"+lotNo+"' <= lot_no__to ";
System.out.println("sql :"+sql);
rs1 = stmt1.executeQuery(sql);
//System.out.println("sql :"+sql);
//rs1 = stmt1.executeQuery(sql);
pstmt1 = conn1.prepareStatement(sql);
rs1 = pstmt1.executeQuery();
if (rs1.next())
{
shipperSize = rs1.getDouble(1);
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
System.out.println("shipperSize .............:"+shipperSize);
System.out.println("minputQty .............:"+minputQty);
if( shipperSize > 0)
......@@ -2470,38 +2619,57 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
remainder = minputQty % shipQty;
//System.out.println("remainder .............:"+remainder);
sql ="select ( case when integral_qty is null then 0 else integral_qty end) integral_qty"
+" from customeritem where cust_code = '"+sundryCode+"' and item_code ='"+itemCode+"'";
System.out.println("sql :"+sql);
rs1 = stmt1.executeQuery(sql);
//+" from customeritem where cust_code = '"+sundryCode+"' and item_code ='"+itemCode+"'";
+" from customeritem where cust_code = ? and item_code = ?";
//System.out.println("sql :"+sql);
//rs1 = stmt1.executeQuery(sql);
pstmt1 = conn1.prepareStatement(sql);
pstmt1.setString(1, sundryCode);
pstmt1.setString(2, itemCode);
rs1 = pstmt1.executeQuery();
if (rs1.next())
{
integralqty = rs1.getDouble(1);
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
//System.out.println("integralqty .............:"+integralqty);
if(integralqty ==0)
{
sql ="select ( case when integral_qty is null then 0 else integral_qty end) integral_qty"
+" from siteitem where site_code = '"+siteCode+"' and item_code ='"+itemCode+"'";
System.out.println("sql :"+sql);
rs1 = stmt1.executeQuery(sql);
//+" from siteitem where site_code = '"+siteCode+"' and item_code ='"+itemCode+"'";
+" from siteitem where site_code = ? and item_code = ?";
//System.out.println("sql :"+sql);
//rs1 = stmt1.executeQuery(sql);
pstmt1 = conn1.prepareStatement(sql);
pstmt1.setString(1, siteCode);
pstmt1.setString(2, itemCode);
rs1 = pstmt1.executeQuery();
if (rs1.next())
{
integralqty = rs1.getDouble(1);
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
//System.out.println("integralqty .............:"+integralqty);
if(integralqty ==0)
{
sql ="select ( case when integral_qty is null then 0 else integral_qty end) integral_qty"
+" from item where item_code ='"+itemCode+"'";
System.out.println("sql :"+sql);
rs1 = stmt1.executeQuery(sql);
+" from item where item_code = ? ";//'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs1 = stmt1.executeQuery(sql);
pstmt1 = conn1.prepareStatement(sql);
pstmt1.setString(1, itemCode);
rs1 = pstmt1.executeQuery();
if (rs1.next())
{
integralqty = rs1.getDouble(1);
//System.out.println("integralqty .............:"+integralqty);
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
}
}
......@@ -2634,7 +2802,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
}*///Added by Pavan R on 29MAR2018[END]
}//while end
rs.close(); rs = null;
pstmt.close(); pstmt = null;
//changed by msalam on 22/09/07 start
//if no record found then promp error
System.out.println("manohar 08/08/11 isRecordFound [" + isRecordFound + "] partQty [" + partQty + "]" );
......@@ -2725,13 +2894,16 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
//End Add Gulzar 01/03/07
//System.out.println("sql1 :"+sql1);
rs1 = stmt1.executeQuery(sql1);
//rs1 = stmt1.executeQuery(sql1);
pstmt1 = conn1.prepareStatement(sql1);
rs1 = pstmt1.executeQuery();
if (rs1.next())
{
count = rs1.getInt(1);
//System.out.println("count :"+count);
}
rs1.close();
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
System.out.println("manohar 08/08/11 count [" + count + "] partQty [" + partQty + "]" );
if (count == 0 && "X".equalsIgnoreCase(partQty))
{
......@@ -2761,7 +2933,9 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+" AND B.STAT_TYPE = 'M' "
+"AND A.LOC_CODE IN ("+locCodeDamaged+")"; //Gulzar 01/03/07 as changes done by Prajakta in PB code.
//System.out.println("sql1 :"+sql1);
rs1 = stmt1.executeQuery(sql1);
//rs1 = stmt1.executeQuery(sql1);
pstmt1 = conn1.prepareStatement(sql1);
rs1 = pstmt1.executeQuery();
if (rs1.next())
{
expDate = rs1.getDate(1);
......@@ -2777,6 +2951,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
rate2 = rs1.getDouble(6);
//System.out.println("rate2 :"+rate2);
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
}
else if (CommonConstants.DB_NAME.equalsIgnoreCase("mssql"))
{
......@@ -2798,7 +2974,9 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+" AND B.STAT_TYPE = 'M' "
+"AND A.LOC_CODE IN ("+locCodeDamaged+")"; //Gulzar 01/03/07 as changes done by Prajakta in PB code.
//System.out.println("sql1 :"+sql1);
rs1 = stmt1.executeQuery(sql1);
//rs1 = stmt1.executeQuery(sql1);
pstmt1 = conn1.prepareStatement(sql1);
rs1 = pstmt1.executeQuery();
if (rs1.next())
{
expDate = rs1.getDate(1);
......@@ -2814,6 +2992,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
rate2 = rs1.getDouble(6);
//System.out.println("rate2 :"+rate2);
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
}
else
{
......@@ -2833,8 +3013,10 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+"AND B.AVAILABLE = '"+availableYn+"' "
+"AND B.USABLE = '"+availableYn+"' " //+" FOR UPDATE NOWAIT"; // commented becz out of sequence error occurs
+"AND A.LOC_CODE IN ('"+locCodeDamaged+"')"; //Gulzar 01/03/07 as changes done by Prajakta in PB code.
System.out.println("sql1 :"+sql1);
rs1 = stmt1.executeQuery(sql1);
//System.out.println("sql1 :"+sql1);
//rs1 = stmt1.executeQuery(sql1);
pstmt1 = conn1.prepareStatement(sql1);
rs1 = pstmt1.executeQuery();
if (rs1.next())
{
expDate = rs1.getDate(1);
......@@ -2850,6 +3032,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
rate2 = rs1.getDouble(6);
//System.out.println("rate2 :"+rate2);
}
rs1.close(); rs1 = null;
pstmt1.close(); pstmt1 = null;
}
java.util.Date expDate1 = null;
if (minShelfLife > 0)
......@@ -2977,8 +3161,29 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
conn1.close();
conn1 = null;
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(rs1 != null) {
rs1.close(); rs1 = null;
}
if(pstmt1 != null) {
pstmt1.close(); pstmt1 = null;
}
if(rs2 != null) {
rs2.close(); rs2 = null;
}
if(pstmt2 != null) {
pstmt2.close(); pstmt2 = null;
}
if(conn1 != null)
{
conn1.close();
conn1 = null;
}
}
catch (Exception e){}
}
......@@ -2996,11 +3201,12 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
ResultSet rs = null;
Connection conn = null;
Statement stmt = null;
//Statement stmt = null;
PreparedStatement pstmtS = null;
PreparedStatement pstmt = null; //added by Jiten on 20/03/06 for change in sql
Document dom = null, dom1 = null, domItmChng = null;
ibase.utility.E12GenericUtility genericUtility= new ibase.utility.E12GenericUtility();
ConnDriver connDriver = new ConnDriver();
//ConnDriver connDriver = new ConnDriver();
Node parentNode = null, parentNode1 = null, childNode = null , childNode1 = null;
NodeList parentNodeList = null, childNodeList = null, parentNodeList1 = null, childNodeList1 = null;
int parentNodeListLen = 0, childNodeListLen = 0, parentNodeListLen1 = 0, childNodeListLen1 = 0;
......@@ -3046,7 +3252,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
stmt = conn.createStatement();
//stmt = conn.createStatement();
//distOrder = genericUtility.getColumnValue("dist_order",dom1);
//COMMENTED ABOVE AND ADDED BELOW LINE FOR REQ ID DI89MAN022 //mukesh 24 sept 08
distOrder = genericUtility.getColumnValue("dist_order",dom);
......@@ -3076,7 +3282,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
String tranType = null;
String tranTypeParent = null;
Statement stmtS = conn.createStatement();
//Statement stmtS = conn.createStatement();
ResultSet rsS = null;
tranType = genericUtility.getColumnValue("tran_type",dom1);
/* sql = " SELECT dtl.LINE_NO, dtl.ITEM_CODE, "
......@@ -3117,7 +3323,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+" AND ( CASE WHEN dtl.SHIP_DATE IS NULL THEN dtl.DUE_DATE ELSE dtl.SHIP_DATE END ) <= ? "
+" AND (( CASE WHEN dtl.QTY_CONFIRM IS NULL THEN 0 ELSE dtl.QTY_CONFIRM END ) - "
+" ( CASE WHEN dtl.QTY_SHIPPED IS NULL THEN 0 ELSE dtl.QTY_SHIPPED END) ) > 0 ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setTimestamp(1,java.sql.Timestamp.valueOf(genericUtility.getValidDateTimeString(tranDate,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat())));
rs = pstmt.executeQuery();
......@@ -3152,9 +3358,12 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
// 15/04/10 manoharan
valueXmlString.append("<pack_code>").append("<![CDATA[").append( ( packCode == null ? "" : packCode ) ).append("]]>").append("</pack_code>");
// end 15/04/10 manoharan
sql = "SELECT TRAN_TYPE__PARENT FROM DISTORDER_TYPE WHERE TRAN_TYPE ='"+tranType+"'";
System.out.println("sql :"+sql);
rsS = stmtS.executeQuery(sql);
sql = "SELECT TRAN_TYPE__PARENT FROM DISTORDER_TYPE WHERE TRAN_TYPE = ?";//'"+tranType+"'";
//System.out.println("sql :"+sql);
//rsS = stmtS.executeQuery(sql);
pstmtS = conn.prepareStatement(sql);
pstmtS.setString(1, tranType);
rsS = pstmtS.executeQuery();
if ( rsS.next() )
{
tranTypeParent = rsS.getString( "TRAN_TYPE__PARENT" );
......@@ -3162,6 +3371,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
rsS.close();
rsS = null;
pstmtS.close(); pstmtS = null;
if ( !tranType.equals( tranTypeParent ) )
{
quantityNoArt = cQtyShipped;
......@@ -3336,8 +3546,10 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
valueXmlString = new StringBuffer();
}//end while
stmtS.close();
stmtS = null;
//stmtS.close();
//stmtS = null;
rs.close(); rs = null;
pstmt.close(); pstmt = null;
retStrFrAllocate.append("</Root>");
System.out.println("retStrFrAllocate :"+retStrFrAllocate);
}//try end
......@@ -3403,7 +3615,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
type = priceListType(priceList);
System.out.println("type :"+type);
ArrayList returnList = null;
ConnDriver connDriver = new ConnDriver(); //Gulzar 01/03/07
//ConnDriver connDriver = new ConnDriver(); //Gulzar 01/03/07
try
{
returnList = genericUtility.getTokenList(lotNo,"\t");
......@@ -3449,7 +3661,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
pstmt.setTimestamp(3,java.sql.Timestamp.valueOf(genericUtility.getValidDateTimeString(tranDate,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat())));
pstmt.setTimestamp(4,java.sql.Timestamp.valueOf(genericUtility.getValidDateTimeString(tranDate,genericUtility.getApplDateFormat(),genericUtility.getDBDateFormat())));
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
rs = pstmt.executeQuery();
if (rs.next())
{
......@@ -3458,9 +3670,11 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
sql = "SELECT CASE WHEN PRICE_LIST__PARENT IS NULL THEN '' ELSE PRICE_LIST__PARENT END "
+"FROM PRICELIST WHERE PRICE_LIST = ? AND LIST_TYPE = 'L' ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
rs = pstmt.executeQuery();
......@@ -3469,12 +3683,14 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
priceListParent = rs.getString(1);
System.out.println("priceListParent :"+priceListParent);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (priceListParent.trim().length() > 0)
{
sql = "SELECT RATE FROM PRICELIST WHERE PRICE_LIST = ? "
+"AND ITEM_CODE = ? AND LIST_TYPE = 'L' "
+"AND EFF_FROM <= ? AND VALID_UPTO >= ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceListParent);
pstmt.setString(2,itemCode);
......@@ -3492,6 +3708,9 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
//retValue = -1;//Changed by Manoj dtd 09/10/2014
return -1;
}
......@@ -3511,7 +3730,16 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
conn.close();
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(conn != null) {
conn.close(); conn = null;
}
//conn.close();
}catch(Exception e){}
}
break;
......@@ -3525,7 +3753,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
sql = "SELECT RATE FROM PRICELIST WHERE PRICE_LIST = ? "
+"AND ITEM_CODE = ? AND LIST_TYPE = 'F' "
+"AND EFF_FROM <= ? AND VALID_UPTO >= ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
pstmt.setString(2,itemCode);
......@@ -3543,9 +3771,11 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
sql = "SELECT CASE WHEN PRICE_LIST__PARENT IS NULL THEN '' ELSE PRICE_LIST__PARENT END "
+"FROM PRICELIST WHERE PRICE_LIST = ? AND LIST_TYPE = 'L' ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
rs = pstmt.executeQuery();
......@@ -3553,12 +3783,14 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
priceListParent = rs.getString(1);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (priceListParent.trim().length() > 0)
{
sql = "SELECT RATE FROM PRICELIST WHERE PRICE_LIST = ? "
+"AND ITEM_CODE = ? AND LIST_TYPE = 'F' "
+"AND EFF_FROM <= ? AND VALID_UPTO >= ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceListParent);
pstmt.setString(2,itemCode);
......@@ -3574,6 +3806,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
//retValue = -1;//Changed by Manoj dtd 09/10/2014
return -1;
}
......@@ -3593,7 +3827,16 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
conn.close();
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(conn != null) {
conn.close(); conn = null;
}
//conn.close();
}catch(Exception e){}
}
break;
......@@ -3607,7 +3850,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
sql = "SELECT RATE FROM PRICELIST WHERE PRICE_LIST = ? "
+"AND ITEM_CODE = ? AND LIST_TYPE = 'L' "
+"AND EFF_FROM <= ? AND VALID_UPTO >= ?";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
pstmt.setString(2,itemCode);
......@@ -3623,9 +3866,11 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
sql = "SELECT CASE WHEN PRICE_LIST__PARENT IS NULL THEN '' ELSE PRICE_LIST__PARENT END "
+"FROM PRICELIST WHERE PRICE_LIST = ? AND LIST_TYPE = 'L' ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
rs = pstmt.executeQuery();
......@@ -3633,6 +3878,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
priceListParent = rs.getString(1);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (priceListParent.trim().length() > 0)
{
sql = "SELECT RATE FROM PRICELIST WHERE PRICE_LIST = ? "
......@@ -3653,6 +3900,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
rate = rs.getDouble(1);
System.out.println("rate :"+rate);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}//end if
else
{
......@@ -3663,7 +3912,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+"AND LOT_NO__TO >= ? "
+"AND EFF_FROM <= ? "
+"AND VALID_UPTO >= ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
pstmt.setString(2,itemCode);
......@@ -3680,9 +3929,11 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
sql = "SELECT CASE WHEN PRICE_LIST__PARENT IS NULL THEN '' ELSE PRICE_LIST__PARENT END "
+"FROM PRICELIST WHERE PRICE_LIST = ? AND LIST_TYPE = 'B'";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
rs = pstmt.executeQuery();
......@@ -3691,6 +3942,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
priceListParent = rs.getString(1);
System.out.println("priceListParent :"+priceListParent);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (priceListParent.trim().length() > 0)
{
sql = "SELECT RATE FROM PRICELIST WHERE PRICE_LIST = ? "
......@@ -3699,7 +3952,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+"AND LOT_NO__TO >= ? "
+"AND EFF_FROM <= ? "
+"AND VALID_UPTO >= ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
pstmt.setString(2,itemCode);
......@@ -3718,6 +3971,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
//retValue = -1;//Changed by Manoj dtd 09/10/2014
return -1;
}
......@@ -3739,7 +3994,16 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
conn.close();
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(conn != null) {
conn.close(); conn = null;
}
//conn.close();
}catch(Exception e){}
}
......@@ -3758,7 +4022,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+"AND LOT_NO__TO >= ? "
+"AND EFF_FROM <= ? "
+"AND VALID_UPTO >= ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
pstmt.setString(2,itemCode);
......@@ -3777,9 +4041,11 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
sql = "SELECT CASE WHEN PRICE_LIST__PARENT IS NULL THEN '' ELSE PRICE_LIST__PARENT END "
+"FROM PRICELIST WHERE PRICE_LIST = ? AND LIST_TYPE = 'B' ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
rs = pstmt.executeQuery();
......@@ -3788,6 +4054,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
priceListParent = rs.getString(1);
System.out.println("priceListParent :"+priceListParent);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (priceListParent.trim().length() > 0)
{
sql = "SELECT RATE FROM PRICELIST WHERE PRICE_LIST = ? "
......@@ -3796,7 +4064,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+"AND LOT_NO__TO >= ? "
+"AND EFF_FROM <= ? "
+"AND VALID_UPTO >= ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceListParent);
pstmt.setString(2,itemCode);
......@@ -3815,6 +4083,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
//retValue = -1;//Changed by Manoj dtd 09/10/2014
return -1;
}
......@@ -3834,7 +4104,16 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
conn.close();
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(conn != null) {
conn.close(); conn = null;
}
//conn.close();
}catch(Exception e){}
}
break;
......@@ -3852,7 +4131,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+"AND ITEM_CODE = ? AND LIST_TYPE = '"+type+"' "
+"AND EFF_FROM <= ? "
+"AND VALID_UPTO >= ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
pstmt.setString(2,itemCode);
......@@ -3869,9 +4148,11 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
sql = "SELECT CASE WHEN PRICE_LIST__PARENT IS NULL THEN '' ELSE PRICE_LIST__PARENT END "
+"FROM PRICELIST WHERE PRICE_LIST = ? AND LIST_TYPE = ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceList);
pstmt.setString(2,String.valueOf(type));
......@@ -3880,13 +4161,15 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
priceListParent = rs.getString(1);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (priceListParent.trim().length() > 0)
{
sql = "SELECT RATE FROM PRICELIST WHERE PRICE_LIST = ? "
+"AND ITEM_CODE = ? AND LIST_TYPE = ? "
+"AND EFF_FROM <= ? "
+"AND VALID_UPTO >= ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,priceListParent);
pstmt.setString(2,itemCode);
......@@ -3904,6 +4187,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
else
{
rs.close(); rs = null;
pstmt.close(); pstmt = null;
//retValue = -1;//Changed by Manoj dtd 09/10/2014
return -1;
}
......@@ -3923,7 +4208,16 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
conn.close();
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(conn != null) {
conn.close(); conn = null;
}
//conn.close();
}catch(Exception e){}
}
break;
......@@ -3941,7 +4235,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+"AND SITE_CODE = ? "
+"AND LOC_CODE = ? "
+"AND LOT_NO = ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,itemCode);
pstmt.setString(2,siteCode);
......@@ -3954,6 +4248,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
rate = rs.getDouble(1);
System.out.println("rate :"+rate);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
else
{
......@@ -3962,7 +4258,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
+"AND LOC_CODE = ? "
+"AND LOT_NO = ? "
+"AND LOT_SL = ? ";
System.out.println("sql :"+sql);
//System.out.println("sql :"+sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1,itemCode);
pstmt.setString(2,siteCode);
......@@ -3976,6 +4272,8 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
rate = rs.getDouble(1);
System.out.println("rate :"+rate);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
}
catch(Exception e)
......@@ -3986,7 +4284,16 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
conn.close();
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(conn != null) {
conn.close(); conn = null;
}
//conn.close();
}catch(Exception e){}
}
}//end switch
......@@ -4001,18 +4308,22 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
String sql = "";
ResultSet rs = null;
Connection conn = null;
Statement stmt = null;
ConnDriver connDriver = new ConnDriver();
//Statement stmt = null;
PreparedStatement pstmt = null;
//ConnDriver connDriver = new ConnDriver();
try
{
//Changes and Commented By Bhushan on 09-06-2016 :START
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
stmt = conn.createStatement();
sql = "SELECT LIST_TYPE FROM PRICELIST WHERE PRICE_LIST = '"+priceList+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
//stmt = conn.createStatement();
sql = "SELECT LIST_TYPE FROM PRICELIST WHERE PRICE_LIST = ? ";//'"+priceList+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, priceList);
rs = pstmt.executeQuery();
if (rs.next())
{
System.out.println("rs.getString(1) :"+rs.getString(1));
......@@ -4030,7 +4341,9 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
listType = ' ';
}
conn.close();
rs.close(); rs = null;
pstmt.close(); pstmt = null;
//conn.close();
}//try end
catch(SQLException sqx)
{
......@@ -4044,8 +4357,23 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
try
{
conn.close();
stmt = null;
if(rs != null)
{
rs.close();
rs = null;
}
if(pstmt != null)
{
pstmt.close();
pstmt = null;
}
if(conn != null)
{
conn.close();
conn = null;
}
//conn.close();
//stmt = null;
}catch(Exception e){}
}// finally end
System.out.println("listType :"+listType);
......@@ -4094,8 +4422,9 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
String sql = "";
ResultSet rs = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
Statement stmt = null;
//ConnDriver connDriver = new ConnDriver();
//Statement stmt = null;
PreparedStatement pstmt = null;
try
{
//System.out.println("$%$%$%$%$%$%Inside getIntegralQty function&*&*&*&*&");
......@@ -4103,7 +4432,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
stmt = conn.createStatement();
//stmt = conn.createStatement();
char type = checkIntegralQty.charAt(0);
//System.out.println("type==>"+type);
switch (type)
......@@ -4111,49 +4440,73 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
case 'S':
sql ="SELECT CASE WHEN SHIPPER_SIZE IS NULL THEN 0 ELSE SHIPPER_SIZE END "
+"FROM ITEM_LOT_PACKSIZE "
+"WHERE ITEM_CODE = '"+itemCode+"' "
+"AND LOT_NO__FROM <= '"+lotNo+"' "
+"AND LOT_NO__TO >= '"+lotNo+"' ";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
+"WHERE ITEM_CODE = ? "//'"+itemCode+"' "
+"AND LOT_NO__FROM <= ? "//'"+lotNo+"' "
+"AND LOT_NO__TO >= ? ";//'"+lotNo+"' ";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
pstmt.setString(2, lotNo);
pstmt.setString(3, lotNo);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (integralQty == 0)
{
sql = "SELECT CASE WHEN CAPACITY IS NULL THEN 0 ELSE CAPACITY END "
+"FROM PACKING WHERE PACK_CODE = '"+packCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
+"FROM PACKING WHERE PACK_CODE = ?"; //'"+packCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, packCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (integralQty == 0)
{
sql = "SELECT REO_QTY FROM SITEITEM "
+"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
//+"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
+"WHERE SITE_CODE = ? AND ITEM_CODE = ?";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCode);
pstmt.setString(2, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (integralQty == 0)
{
sql = "SELECT REO_QTY FROM ITEM "
+"WHERE ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
+"WHERE ITEM_CODE = ? ";//'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
}
}
......@@ -4161,36 +4514,53 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
break;
case 'P':
sql = "SELECT CASE WHEN CAPACITY IS NULL THEN 0 ELSE CAPACITY END "
+"FROM PACKING WHERE PACK_CODE = '"+packCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
+"FROM PACKING WHERE PACK_CODE = ?";//'"+packCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, packCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
System.out.println("integralQty = ["+integralQty+"]");
break;
case 'I':
sql = "SELECT INTEGRAL_QTY FROM SITEITEM "
+"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
//+"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
+"WHERE SITE_CODE = ? AND ITEM_CODE = ?";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCode);
pstmt.setString(2, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (integralQty == 0)
{
sql = "SELECT INTEGRAL_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
sql = "SELECT INTEGRAL_QTY FROM ITEM WHERE ITEM_CODE = ? ";//'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
System.out.println("integralQty from getIntegralQty function = ["+integralQty+"]");
}
......@@ -4241,11 +4611,24 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
}
}
} */
conn.close();
//conn.close();
}
catch(Exception e)
{
System.out.println("the exception occurs in getIntegralQty :"+e);
}finally
{
try{
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(conn != null) {
conn.close(); conn = null;
}
}catch(Exception e){}
}
System.out.println("integralQty :"+integralQty);
return integralQty;
......@@ -4256,8 +4639,9 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
String sql = "";
ResultSet rs = null;
Connection conn = null;
ConnDriver connDriver = new ConnDriver();
Statement stmt = null;
//ConnDriver connDriver = new ConnDriver();
//Statement stmt = null;
PreparedStatement pstmt = null;
double reoQty = 0d, capacity = 0d, integralQty = 0d, mod = 0d, noArt3 = 0d;
double noArt = 0, noArt1 = 0, noArt2 = 0;
try
......@@ -4266,14 +4650,18 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
//conn = connDriver.getConnectDB("DriverITM");
conn = getConnection();
//Changes and Commented By Bhushan on 09-06-2016 :END
stmt = conn.createStatement();
//stmt = conn.createStatement();
System.out.println("type :"+type);
switch (type)
{
case 'S':
sql = "SELECT CASE WHEN CAPACITY IS NULL THEN 0 ELSE CAPACITY END "
+"FROM PACKING WHERE PACK_CODE = '"+packCode+"'";
rs = stmt.executeQuery(sql);
+"FROM PACKING WHERE PACK_CODE = ?";//'"+packCode+"'";
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, packCode);
rs = pstmt.executeQuery();
if (rs.next())
{
capacity = rs.getDouble(1);
......@@ -4283,25 +4671,38 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
capacity = 0;
}
sql = "SELECT REO_QTY FROM SITEITEM WHERE SITE_CODE = '"+siteCode+"' "
+"AND ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
rs.close(); rs = null;
pstmt.close(); pstmt = null;
sql = "SELECT REO_QTY FROM SITEITEM WHERE SITE_CODE = ? "//'"+siteCode+"' "
+"AND ITEM_CODE = ?"; //'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCode);
pstmt.setString(2, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
reoQty = rs.getDouble(1);
System.out.println("reoQty :"+reoQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if( reoQty == 0 )
{
sql = "SELECT REO_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
sql = "SELECT REO_QTY FROM ITEM WHERE ITEM_CODE = ?"; //'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
reoQty = rs.getDouble(1);
System.out.println("reoQty :"+reoQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
if (reoQty == 0)
{
......@@ -4328,35 +4729,54 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
break;
case 'I':
sql = "SELECT INTEGRAL_QTY FROM CUSTOMERITEM "
+"WHERE CUST_CODE = '"+custCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
//+"WHERE CUST_CODE = '"+custCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
+"WHERE CUST_CODE = ? AND ITEM_CODE = ?";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, custCode);
pstmt.setString(2, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (integralQty == 0)
{
sql = "SELECT INTEGRAL_QTY FROM SITEITEM "
+"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
//+"WHERE SITE_CODE = '"+siteCode+"'"+" AND ITEM_CODE = '"+itemCode+"'";
+"WHERE SITE_CODE = ? AND ITEM_CODE = ?";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCode);
pstmt.setString(2, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if( integralQty == 0 )
{
sql = "SELECT INTEGRAL_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
sql = "SELECT INTEGRAL_QTY FROM ITEM WHERE ITEM_CODE = ?";//'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
}
if (integralQty > 0)
......@@ -4369,9 +4789,12 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
break;
case 'B' :
sql = "SELECT CASE WHEN CAPACITY IS NULL THEN 0 ELSE CAPACITY END "
+"FROM PACKING WHERE PACK_CODE = '"+packCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
+"FROM PACKING WHERE PACK_CODE = ?";//'"+packCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, packCode);
rs = pstmt.executeQuery();
if (rs.next())
{
capacity = rs.getDouble(1);
......@@ -4381,25 +4804,38 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
capacity = 0;
}
sql = "SELECT REO_QTY FROM SITEITEM WHERE SITE_CODE = '"+siteCode+"' "
+"AND ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
rs.close(); rs = null;
pstmt.close(); pstmt = null;
sql = "SELECT REO_QTY FROM SITEITEM WHERE SITE_CODE = ?" //'"+siteCode+"' "
+"AND ITEM_CODE = ? ";//'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCode);
pstmt.setString(2, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
reoQty = rs.getDouble(1);
//System.out.println("reoQty :"+reoQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if( reoQty == 0 )
{
sql = "SELECT REO_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
sql = "SELECT REO_QTY FROM ITEM WHERE ITEM_CODE = ?"; //'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
reoQty = rs.getDouble(1);
//System.out.println("reoQty :"+reoQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
if (capacity > 0)
{
......@@ -4419,37 +4855,54 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
//System.out.println("noArt1 :"+noArt1);
}
sql = "SELECT INTEGRAL_QTY FROM CUSTOMERITEM "
+"WHERE CUST_CODE = '"+custCode+"' "
+"AND ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
+"WHERE CUST_CODE = ? "//'"+custCode+"' "
+"AND ITEM_CODE = ?";//'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, custCode);
pstmt.setString(2, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if (integralQty == 0)
{
sql ="SELECT INTEGRAL_QTY FROM SITEITEM "
+"WHERE SITE_CODE = '"+siteCode+"' "
+"AND ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
+"WHERE SITE_CODE = ? "//'"+siteCode+"' "
+"AND ITEM_CODE = ? ";//'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCode);
pstmt.setString(2, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
if(integralQty == 0)
{
sql = "SELECT INTEGRAL_QTY FROM ITEM WHERE ITEM_CODE = '"+itemCode+"'";
System.out.println("sql :"+sql);
rs = stmt.executeQuery(sql);
sql = "SELECT INTEGRAL_QTY FROM ITEM WHERE ITEM_CODE = ?";//'"+itemCode+"'";
//System.out.println("sql :"+sql);
//rs = stmt.executeQuery(sql);
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, itemCode);
rs = pstmt.executeQuery();
if (rs.next())
{
integralQty = rs.getDouble(1);
//System.out.println("integralQty :"+integralQty);
}
rs.close(); rs = null;
pstmt.close(); pstmt = null;
}
}
double remainder1 = 0d;
......@@ -4469,7 +4922,7 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
noArt = noArt1 + noArt2;
System.out.println("noArt :"+noArt);
}
conn.close();
//conn.close();
if (noArt == 0)
{
noArt = 0;
......@@ -4479,6 +4932,20 @@ public class DistIssueAct extends ActionHandlerEJB implements DistIssueActLocal,
{
System.out.println("Exception occures in getNoArt :"+e);
}
finally {
try{
if(rs != null) {
rs.close(); rs = null;
}
if(pstmt != null) {
pstmt.close(); pstmt = null;
}
if(conn != null)
{
conn.close(); conn = null;
}
}catch(Exception e){}
}
System.out.println("(int)noArt :"+(int)noArt);
return (int)noArt;
}
......
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