Skip to content

B
business-java
Commit 561cb19b authored by rtiwari's avatar rtiwari
Browse files
Options

updated 


git-svn-id: http://15.206.35.175/svn/proteus/business-java/trunk@94139 ce508802-f39f-4f6c-b175-0d175dae99d5
parent db8297ba
Hide whitespace changes
Inline Side-by-side
Showing with 1545 additions and 6 deletions
webitm-mfg/ibase/webitm/ejb/mfg/WoTransferPrc.java
View file @ 561cb19b
...@@ -15,11 +15,13 @@ import java.sql.Connection; ...@@ -15,11 +15,13 @@ import java.sql.Connection;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.ResultSet; import java.sql.ResultSet;
import java.sql.SQLException; import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp; import java.sql.Timestamp;
import java.text.DecimalFormat; import java.text.DecimalFormat;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.Date; import java.util.Date;
import java.util.HashMap;
import java.util.logging.Level; import java.util.logging.Level;
import java.util.logging.Logger; import java.util.logging.Logger;
import javax.ejb.Stateless; import javax.ejb.Stateless;
...@@ -27,6 +29,8 @@ import javax.naming.InitialContext; ...@@ -27,6 +29,8 @@ import javax.naming.InitialContext;
import org.w3c.dom.Document; import org.w3c.dom.Document;
import org.w3c.dom.Node; import org.w3c.dom.Node;
import org.w3c.dom.NodeList; import org.w3c.dom.NodeList;
import ibase.webitm.ejb.dis.InvAllocTraceBean;
import ibase.webitm.ejb.dis.StockUpdate;
//import ibase.webitm.ejb.dis.InvAllocTrace; //import ibase.webitm.ejb.dis.InvAllocTrace;
import ibase.webitm.ejb.dis.adv.StockTransferConf; import ibase.webitm.ejb.dis.adv.StockTransferConf;
...@@ -652,7 +656,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr ...@@ -652,7 +656,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
list.add(lineno); list.add(lineno);
list.add(itemCode); list.add(itemCode);
elements ++; elements ++;
System.out.println(" QUANTITY TO BE ALLOCATED NOT VALID"); System.out.println("QUANTITY TO BE ALLOCATED NOT VALID");
} }
}// out for loop }// out for loop
...@@ -760,7 +764,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr ...@@ -760,7 +764,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
String userId = ""; String userId = "";
String termId = ""; String termId = "";
String sql = "",sql1="", acctCodeInv1 = "",cctrCodeInv1=""; String sql = "",sql1="", acctCodeInv1 = "",cctrCodeInv1="";
String itemSer="",tranType=""; String itemSer="",tranType="",noArt="";
Date orddate = null; Date orddate = null;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
ResultSet rs = null; ResultSet rs = null;
...@@ -770,8 +774,41 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr ...@@ -770,8 +774,41 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
String empCode = ""; String empCode = "";
String xmlString = ""; String xmlString = "";
StringBuffer xmlBuff = null; StringBuffer xmlBuff = null;
String invStatLocCodeTo ="";
HashMap stockMap = null;
ArrayList errList = null;
java.sql.Timestamp expDate = null;
java.sql.Timestamp mfgDate = null;
java.sql.Timestamp restestDate = null;
String packCode = "";
String siteCodeMfg = "";
String packInstr = "";
String suppCodeMfg = "";
String unitAlt = "";
String batchNo = "";
String unit = "";
String grade = "";
String remarks1 = "";
String dimension = "";
String acctCodeDr = "";
String ediOption = "";
String dataStr = "";
String chgTerm = "";
double grossRate = 0d;
double convQtyStduom = 0d;
double batchSize = 0d;
double stkGrossRate = 0d;
double stkRate = 0d;
double actualRate = 0d;
double stkQuantity = 0,holdQuantity = 0;
double holdQty = 0;
double potencyPerc=0,grossWeight=0,tareWeight=0,netWeight=0;
try try
{ {
System.out.println("@@@@@@@ wostock trans. function called::"); System.out.println("@@@@@@@ wostock trans. function called::");
xmlBuff = new StringBuffer(); xmlBuff = new StringBuffer();
genericUtility = GenericUtility.getInstance(); genericUtility = GenericUtility.getInstance();
...@@ -780,6 +817,8 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr ...@@ -780,6 +817,8 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
currDate = java.sql.Timestamp.valueOf(sdf1.format(new java.util.Date()).toString() + " 00:00:00.0"); currDate = java.sql.Timestamp.valueOf(sdf1.format(new java.util.Date()).toString() + " 00:00:00.0");
userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"); System.out.println("--login code--"+userId); userId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "loginCode"); System.out.println("--login code--"+userId);
termId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "termId"); System.out.println("--term id--"+termId); termId = genericUtility.getValueFromXTRA_PARAMS(xtraParams, "termId"); System.out.println("--term id--"+termId);
stockMap = new HashMap();
errList = new ArrayList();
sql = "SELECT EMP_CODE FROM USERS WHERE CODE = ? "; sql = "SELECT EMP_CODE FROM USERS WHERE CODE = ? ";
pstmt = connOne.prepareStatement(sql); pstmt = connOne.prepareStatement(sql);
...@@ -796,7 +835,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr ...@@ -796,7 +835,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
pstmt.close(); pstmt.close();
pstmt = null; pstmt = null;
sql = "select item_code,site_code,bom_code,lot_no,lot_sl,ref_no,ord_date " + sql = "select item_code,site_code,bom_code,lot_no,lot_sl,ref_no,ord_date,no_art " +
" from workorder where work_order = ? "; " from workorder where work_order = ? ";
pstmt = connOne.prepareStatement(sql); pstmt = connOne.prepareStatement(sql);
...@@ -805,6 +844,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr ...@@ -805,6 +844,7 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
if(rs.next()) if(rs.next())
{ {
orddate = rs.getDate("ord_date"); orddate = rs.getDate("ord_date");
noArt = rs.getString("no_art")==null?"0":rs.getString("no_art");
} }
if(rs != null) if(rs != null)
rs.close(); rs.close();
...@@ -928,6 +968,8 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr ...@@ -928,6 +968,8 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
xmlBuff.append("<cctr_code__dr><![CDATA["+ cctrCodeInv1 +"]]></cctr_code__dr>"); xmlBuff.append("<cctr_code__dr><![CDATA["+ cctrCodeInv1 +"]]></cctr_code__dr>");
xmlBuff.append("<no_art><![CDATA["+ noArt +"]]></no_art>");
xmlBuff.append("</Detail2>"); xmlBuff.append("</Detail2>");
xmlBuff.append("</Header0>"); xmlBuff.append("</Header0>");
xmlBuff.append("</group0>"); xmlBuff.append("</group0>");
...@@ -949,9 +991,145 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr ...@@ -949,9 +991,145 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
int endIndex = arrayForTranId[1].indexOf("</TranID>"); int endIndex = arrayForTranId[1].indexOf("</TranID>");
String tranIdForIssue = arrayForTranId[1].substring(0,endIndex); String tranIdForIssue = arrayForTranId[1].substring(0,endIndex);
System.out.println("-tranIdForIssue-"+tranIdForIssue); System.out.println("-tranIdForIssue-"+tranIdForIssue);
StockTransferConf stconf = new StockTransferConf();
retString = stconf.confirm(tranIdForIssue,xtraParams,""); stockMap.put("item_code", itemCode);
System.out.println("retString from confirmStocktrans :: @:: "+retString);//CONFSUCC stockMap.put("site_code", siteCode);
stockMap.put("loc_code", locCodeFr);
stockMap.put("lot_no", lotno);
stockMap.put("lot_sl", lotsl);
double quantity = 0.0;
if(allocQty != null)
{
quantity = Double.parseDouble(allocQty);
}
stockMap.put("quantity", ""+quantity);
sql = "SELECT INV_STAT FROM LOCATION WHERE LOC_CODE = ? ";
pstmt = connOne.prepareStatement(sql);
pstmt.setString(1,locCodeTo);
rs = pstmt.executeQuery();
if(rs.next())
{
invStatLocCodeTo = checkNull(rs.getString("INV_STAT"));
}
if(rs != null)
rs.close();
rs = null;
if(pstmt != null)
pstmt.close();
pstmt = null;
// //if(invStatLocCodeTo.trim().equalsIgnoreCase(locCodeTo.trim()) && invStatLocCodeTo.trim().equalsIgnoreCase(partialGrlLoc.trim()))
// {
// stockMap.put("no_art", allocQty);
// }
// else
// {
stockMap.put("no_art", noArt);
// }
stockMap.put("tran_ser", "XFRX");
stockMap.put("acct_code__cr",acctCodeInv1);
stockMap.put("cctr_code__cr",cctrCodeInv1);
stockMap.put("acct_code_inv",acctCodeInv1);
stockMap.put("cctr_code_inv",cctrCodeInv1);
sql = "select acct_code__inv, cctr_code__inv, "
+ "exp_date, pack_code, mfg_date, site_code__mfg, "
+ "pack_instr, supp_code__mfg, retest_date, "
+ "gross_rate, rate, conv__qty_stduom, unit__alt, batch_no, batch_size, "
+ "unit, grade, remarks, dimension, quantity ,hold_qty,actual_rate ,partial_used "
+ ",potency_perc, inv_stat, gross_weight, tare_weight, net_weight, lot_sl__org " // added by cpatil on 20/11/13 compare with pb code and adding missing field
+ "from stock "
+ "where item_code = ? "
+ "and site_code = ? "
+ "and loc_code = ? "
+ "and lot_no = ? "
+ "and lot_sl = ? ";
pstmt = connOne.prepareStatement(sql);
pstmt.setString(1,itemCode);
pstmt.setString(2,siteCode);
pstmt.setString(3,locCodeFr);
pstmt.setString(4,lotno);
pstmt.setString(5,lotsl);
rs = pstmt.executeQuery();
if ( rs.next() )
{
expDate = rs.getTimestamp("exp_date");
packCode = rs.getString("pack_code");
mfgDate = rs.getTimestamp("mfg_date");
siteCodeMfg = rs.getString("site_code__mfg");
packInstr = rs.getString("pack_instr");
suppCodeMfg = rs.getString("supp_code__mfg");
restestDate = rs.getTimestamp("retest_date");
stkGrossRate = rs.getDouble("gross_rate");
stkRate = rs.getDouble("rate");
System.out.println("stkGrossRate"+stkGrossRate+"stkRate"+stkRate);
convQtyStduom = rs.getDouble("conv__qty_stduom");
unitAlt = rs.getString("unit__alt");
batchNo = rs.getString("batch_no");
batchSize = rs.getDouble("batch_size");
unit = rs.getString("unit");
grade = rs.getString("grade");
remarks1 = rs.getString("remarks");
dimension = rs.getString("dimension");
stkQuantity = rs.getDouble("quantity");
holdQuantity = rs.getDouble("hold_qty");
actualRate = rs.getDouble("actual_rate");
//partialUsed = checkNull(rs.getString("partial_used"));
potencyPerc = rs.getDouble("potency_perc");
grossWeight = rs.getDouble("gross_weight");
tareWeight = rs.getDouble("tare_weight");
netWeight = rs.getDouble("net_weight");
//lotSlOrg = rs.getString("lot_sl__org");
stockMap.put("rate",Double.toString(stkRate));
stockMap.put("gross_rate",Double.toString(stkGrossRate));
System.out.println("stkGrossRate:::"+Double.toString(stkRate)+"stkRate::::"+Double.toString(stkGrossRate));
stockMap.put("tran_id", tranIdForIssue );
stockMap.put("tran_date",currDate );
stockMap.put("qty_stduom", ""+quantity);
stockMap.put("unit",unit);
stockMap.put("grade",grade);
stockMap.put("remarks",remarks1);
stockMap.put("dimension",dimension);
stockMap.put("tran_type", "I");
stockMap.put("exp_date", expDate);
stockMap.put("pack_code", packCode);
stockMap.put("mfg_date", mfgDate);
stockMap.put("site_code__mfg", siteCodeMfg);
stockMap.put("pack_instr", packInstr);
stockMap.put("supp_code__mfg", suppCodeMfg);
stockMap.put("retest_date", restestDate);
stockMap.put("conv__qty_stduom", ""+convQtyStduom);
stockMap.put("unit__alt", unitAlt);
stockMap.put("batch_no", batchNo);
stockMap.put("batch_size", ""+batchSize);
stockMap.put("actual_rate", actualRate);
}
boolean isError = false;
errList = allocTransfer(siteCode,itemCode,locCodeFr ,
lotno,lotsl,locCodeTo ,lotno,lotsl,
quantity,stockMap, xtraParams , connOne );
System.out.println("from alloc transfer=="+errList.toString());
retString = errList.get(0).toString() ;
System.out.println("FROM allocTransfer 0 : "+retString);
if ( retString != null && retString.trim().length() > 0 )
{
isError = true;
}
stockMap.clear();
if(isError == false)
{
StockTransferConf stconf = new StockTransferConf();
retString = stconf.confirm(tranIdForIssue,xtraParams,"");
System.out.println("retString from confirmStocktrans :: @:: "+retString);//CONFSUCC
}
} }
// if((retString != null ) && retString.indexOf("Success") > -1 || retString.indexOf("CONFSUCC") >-1) // if((retString != null ) && retString.indexOf("Success") > -1 || retString.indexOf("CONFSUCC") >-1)
...@@ -1040,4 +1218,1365 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr ...@@ -1040,4 +1218,1365 @@ public class WoTransferPrc extends ProcessEJB implements WoTransferPrcLocal,WoTr
} }
return retString; return retString;
} }
private ArrayList allocTransfer(String siteCode,String itemCode,String locCodeFr ,String lotNoFr,String lotSlFr,String locCodeTo ,String lotNoTo,String lotSlTo,double quantitydet,HashMap stockMap,String xtraParams ,Connection conn ) throws ITMException
{
String errString = "";
String sql = "";
String refSer = "", refId = "" ,tranId = "",workorder = "";
//double pendingQty = 0 ;
int refLine = 0,count = 0,k = 0 ,lineNo = 0 , maxLine = 0;
double quantity = 0 , refQty = 0 ,stockAllocQty = 0 ,invAllocQty = 0,stockQty = 0 ,pendingQty = 0 ;
double splitQty = 0, rate = 0;
boolean checkWOIssue = false;
PreparedStatement pstmt = null ,pstmt1 = null,pstmt2 = null;
Statement stmt = null;
ResultSet rs = null,rs1 = null,rs2 = null;
InvAllocTraceBean invAllocTrace = null;
StockUpdate stkUpdate = null;
ArrayList retValue = new ArrayList();
HashMap hashMap = null;
HashMap tempMap = null ;
try
{
String dbDateFormat = genericUtility.getDBDateFormat();
String applDateFormat = genericUtility.getApplDateFormat();//--
SimpleDateFormat sdfD = new SimpleDateFormat(applDateFormat);//--
java.util.Date currDate1 = new java.util.Date();
String currDateStr = sdfD.format(currDate1);
java.sql.Timestamp tranDate = java.sql.Timestamp.valueOf(genericUtility.getValidDateString( currDateStr , applDateFormat, dbDateFormat ) + " 00:00:00.0") ;
System.out.println("allocTransfer called........");
invAllocTrace = new InvAllocTraceBean();
stkUpdate = new StockUpdate();
pendingQty = quantitydet ;
tempMap = stockMap;
sql = "select alloc_qty from stock where site_code = ? and loc_code = ? and item_code = ? "
+" and lot_no = ? and lot_sl = ? ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCode);
pstmt.setString(2, locCodeFr);
pstmt.setString(3, itemCode);
pstmt.setString(4, lotNoFr);
pstmt.setString(5, lotSlFr);
rs = pstmt.executeQuery();
if(rs.next())
{
stockAllocQty = rs.getDouble("alloc_qty");
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
sql = " select sum(a.qty) from "
+" (select ref_ser,ref_id ,trim(ref_line), sum(alloc_qty) as qty from invalloc_trace where site_code = ? and loc_code = ? and item_code = ? "
+" and lot_no = ? and lot_sl = ? group by ref_ser, ref_id, trim(ref_line) having sum(alloc_qty) > 0 order by sum(alloc_qty) ) a ";
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, siteCode);
pstmt.setString(2, locCodeFr);
pstmt.setString(3, itemCode);
pstmt.setString(4, lotNoFr);
pstmt.setString(5, lotSlFr);
rs = pstmt.executeQuery();
if(rs.next())
{
invAllocQty = rs.getDouble(1);
}
rs.close();
rs = null;
pstmt.close();
pstmt = null;
System.out.println("invAllocQty="+invAllocQty+" stockAllocQty="+stockAllocQty);
if(invAllocQty < stockAllocQty) //check stock allocate qty and invalloc_trace qty
{
checkWOIssue = true;
}
sql = "select ref_ser,ref_id ,trim(ref_line) as ref_line, sum(alloc_qty) from invalloc_trace where "
+" site_code = ? and loc_code = ? and item_code = ? and lot_no = ? and lot_sl = ? "
+" group by ref_ser, ref_id ,trim( ref_line) having sum(alloc_qty) > 0 order by sum(alloc_qty) desc ";
pstmt = conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY,ResultSet.HOLD_CURSORS_OVER_COMMIT);
pstmt.setString(1, siteCode);
pstmt.setString(2, locCodeFr);
pstmt.setString(3, itemCode);
pstmt.setString(4, lotNoFr);
pstmt.setString(5, lotSlFr);
rs = pstmt.executeQuery();
while(rs.next())
{
refSer = checkNull(rs.getString( "ref_ser" )) ;
refId = checkNull(rs.getString( "ref_id" ));
//refLine = rs.getInt("ref_line");
refLine = Integer.parseInt( checkNull(rs.getString("ref_line")).trim().length() == 0 ?"0":rs.getString("ref_line").trim()) ;
refQty = rs.getDouble(4);
System.out.println("pendingQty="+pendingQty);
System.out.println("refSer="+refSer);
System.out.println("refId="+refId);
System.out.println("refLine="+refLine);
System.out.println("refQty="+refQty);
if(pendingQty <= 0)
{
break;
}
if(pendingQty <= refQty)
{
quantity = pendingQty;
pendingQty = 0;
}
else
{
quantity = refQty;
pendingQty = pendingQty - refQty ;
}
stockQty = stockQty + quantity;
hashMap = new HashMap();
hashMap.put("tran_date",tranDate);
hashMap.put("ref_ser",refSer);
hashMap.put("ref_id",refId);
hashMap.put("ref_line",String.valueOf(refLine));
hashMap.put("site_code",siteCode);
hashMap.put("item_code",itemCode);
hashMap.put("loc_code",locCodeFr);
hashMap.put("lot_no",lotNoFr);
hashMap.put("lot_sl",lotSlFr);
hashMap.put("alloc_qty",new Double(-1*quantity));
hashMap.put("chg_user",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"loginCode"));
hashMap.put("chg_term",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"termId"));
errString = invAllocTrace.updateInvallocTrace(hashMap, conn);
System.out.println("updateInvallocTrace 1....."+errString);
if ( errString != null && errString.trim().length() > 0 )
{
retValue.add("Error");
retValue.add(new Double(quantitydet));
return retValue;
}
}//end rs loop
System.out.println("Stock Qty="+stockQty+" pendingQty="+pendingQty);
if (stockQty > 0 && ( errString == null || errString.trim().length() == 0))
{
stockMap.put("quantity", ""+stockQty);
stockMap.put("qty_stduom", ""+stockQty);
//stock update for tran type = "I"
errString = stkUpdate.updateStock( stockMap, xtraParams, conn ); //updateStock called only once's
System.out.println("stock update FOR I ....."+errString);
if ( errString != null && errString.trim().length() > 0 )
{
retValue.add("Error");
retValue.add(new Double(quantitydet));
return retValue;
}
else
{
stockMap = tempMap;
stockMap.put("loc_code", locCodeTo);
stockMap.put("lot_no", lotNoTo);
stockMap.put("lot_sl", lotSlTo);
stockMap.put("tran_type", "R");
//stock update for tran type = "R"
errString = stkUpdate.updateStock( stockMap, xtraParams, conn );
System.out.println("stock update FOR R ....."+errString);
if ( errString != null && errString.trim().length() > 0 )
{
retValue.add("Error");
retValue.add(new Double(quantitydet));
return retValue;
}
}
if ( errString == null || errString.trim().length() == 0)
{
if(rs != null)
{
rs.first();
System.out.println("iterate rs for deallcation ");
pendingQty = quantitydet;
do //iterate rs for deallcation
{
splitQty = 0;
refSer = checkNull(rs.getString( "ref_ser" )) ;
refId = checkNull(rs.getString( "ref_id" ));
// //refLine = rs.getInt("ref_line");
refLine = Integer.parseInt( checkNull(rs.getString("ref_line")).trim().length() == 0 ?"0":rs.getString("ref_line").trim()) ;
refQty = rs.getDouble(4);
System.out.println("quantitydet="+pendingQty);
System.out.println("refSer="+refSer);
System.out.println("refId="+refId);
System.out.println("refLine="+refLine);
System.out.println("refQty="+refQty);
if(pendingQty <= 0)
{
break;
}
if(pendingQty <= refQty)
{
quantity = pendingQty;
pendingQty = 0;
splitQty = refQty - quantity;
}
else
{
quantity = refQty;
pendingQty = pendingQty - refQty ;
}
hashMap = new HashMap();
// hashMap.put("tran_date",new java.sql.Date(System.currentTimeMillis()));
hashMap.put("tran_date",tranDate);
hashMap.put("ref_ser",refSer);
hashMap.put("ref_id",refId);
hashMap.put("ref_line",String.valueOf(refLine));
hashMap.put("site_code",siteCode);
hashMap.put("item_code",itemCode);
hashMap.put("loc_code",locCodeTo);
hashMap.put("lot_no",lotNoTo);
hashMap.put("lot_sl",lotSlTo);
hashMap.put("alloc_qty",new Double(quantity));
hashMap.put("chg_user",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"loginCode"));
hashMap.put("chg_term",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"termId"));
errString = invAllocTrace.updateInvallocTrace(hashMap, conn);
System.out.println("updateInvallocTrace 2....."+errString);
if ( errString != null && errString.trim().length() > 0 )
{
retValue.add("Error");
retValue.add(new Double(quantitydet));
return retValue;
}
else
{
System.out.println("DeAlloc updateInvallocTrace(HashMap, Connection) : Sucessuful!");
System.out.println("refSer:::::"+refSer);
if("S-ORD".equalsIgnoreCase(refSer.trim())) //sale order
{
System.out.println("update for sale order");
maxLine = 0;
System.out.println("update... "+quantity+" "+splitQty);
if(splitQty > 0)//insert new record for split quantity
{
sql = "update sord_alloc_det set loc_code = ? ,lot_no = ? ,lot_sl = ? ,quantity = ? where sale_order = ? and line_no__sord = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeFr);
pstmt1.setString(2,lotNoFr);
pstmt1.setString(3,lotSlFr);
pstmt1.setDouble(4,splitQty);
pstmt1.setString(5,refId);
pstmt1.setInt(6,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated sord_alloc_det ="+k);
pstmt1.close();
pstmt1 = null;
if(k > 0)
{
sql = " select max(line_no) from sord_alloc_det where sale_order = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
maxLine = rs2.getInt(1);
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
maxLine++;
sql = " insert into sord_alloc_det (tran_id,line_no,sale_order,line_no__sord,item_code,loc_code,lot_no,lot_sl,quantity,"
+" dealloc_qty,site_code,exp_lev,pending_qty,wave_flag) "
+" select tran_id,"+maxLine+",sale_order,line_no__sord,item_code,'"+locCodeTo+"','"+lotNoTo+"','"+lotSlTo+"',"+quantity+",dealloc_qty,"
+" site_code,exp_lev,pending_qty,wave_flag from sord_alloc_det where sale_order = ? and line_no__sord = ? ";
System.out.println("insert qry="+sql);
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,refId);
pstmt1.setInt(2,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row inserted sord_alloc_det ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else
{
sql = "update sord_alloc_det set loc_code = ? ,lot_no = ? ,lot_sl = ? where sale_order = ? and line_no__sord = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,refId);
pstmt1.setInt(5,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated sord_alloc_det ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else if("D-ISS".equalsIgnoreCase(refSer.trim())) //1.Distribution Issue (DISS)
{
System.out.println("update for Distribution Issue (DISS)");
rate = 0;
maxLine = 0;
sql = " select rate from distord_issdet where tran_id = ? and line_no = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
pstmt2.setInt(2, refLine);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
rate = rs2.getDouble("rate");
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
System.out.println("update.. "+rate+" "+quantity+" "+splitQty);
if(splitQty > 0)//insert new record for split quantity
{
sql = " update distord_issdet set loc_code = ? ,lot_no = ? ,lot_sl = ? , quantity = ?,amount = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeFr);
pstmt1.setString(2,lotNoFr);
pstmt1.setString(3,lotSlFr);
pstmt1.setDouble(4,splitQty);
pstmt1.setDouble(5,splitQty*rate);
pstmt1.setString(6,refId);
pstmt1.setInt(7,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated distord_issdet ="+k);
pstmt1.close();
pstmt1 = null;
if(k > 0)
{
sql = " select max(line_no) from distord_issdet where tran_id = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
maxLine = rs2.getInt(1);
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
maxLine++;
sql = " insert into distord_issdet (tran_id,line_no,dist_order,line_no_dist_order,item_code,quantity,unit,tax_class,tax_chap,tax_env,loc_code,lot_no,lot_sl,"
+" pack_code,rate,amount,tax_amt,net_amt,site_code__mfg,mfg_date,exp_date,potency_perc,no_art,gross_weight,tare_weight,net_weight,pack_instr,dimension,"
+" supp_code__mfg,batch_no,grade,retest_date,rate_clg,rate__clg,discount,disc_amt,remarks,cost_rate,unit__alt,conv__qty__alt,qty_order__alt,pallet_wt,"
+" rate__alt,conv__rate_alt,return_qty,return_date,returned,batch_size,carton_no,pallet_no) "
+" select tran_id,"+maxLine+",dist_order,line_no_dist_order,item_code,"+quantity+",unit,tax_class,tax_chap,tax_env,'"+locCodeTo+"','"+lotNoTo+"','"+lotSlTo+"',"
+" pack_code,rate,15*2,tax_amt,net_amt,site_code__mfg,mfg_date,exp_date,potency_perc,no_art,gross_weight,tare_weight,net_weight,"
+" pack_instr,dimension,supp_code__mfg,batch_no,grade,retest_date,rate_clg,rate__clg,discount,disc_amt,remarks,cost_rate,unit__alt,"
+" conv__qty__alt,qty_order__alt,pallet_wt,rate__alt,conv__rate_alt,return_qty,return_date,returned,batch_size,carton_no,pallet_no from distord_issdet where tran_id = ? and line_no = ? ";
System.out.println("insert qry="+sql);
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,refId);
pstmt1.setInt(2,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row inserted distord_issdet ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else
{
sql = " update distord_issdet set loc_code = ? ,lot_no = ? ,lot_sl = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,refId);
pstmt1.setInt(5,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated distord_issdet ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else if("S-DSP".equalsIgnoreCase(refSer.trim())) //Despatch
{
System.out.println("update for Despatch");
maxLine = 0;
System.out.println("update... "+quantity+" "+splitQty);
if(splitQty > 0)//insert new record for split quantity
{
sql = " update despatchdet set loc_code = ? ,lot_no = ? ,lot_sl = ? ,quantity = ?,quantity__ord = ?,quantity__stduom = ? where desp_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeFr);
pstmt1.setString(2,lotNoFr);
pstmt1.setString(3,lotSlFr);
pstmt1.setDouble(4,splitQty);
pstmt1.setDouble(5,splitQty);
pstmt1.setDouble(6,splitQty);
pstmt1.setString(7,refId);
pstmt1.setInt(8,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated despatchdet ="+k);
pstmt1.close();
pstmt1 = null;
if(k > 0)
{
sql = " select max( line_no) from despatchdet where desp_id = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
maxLine = rs2.getInt(1);
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
maxLine++;
sql = " insert into despatchdet (desp_id,line_no,sord_no,line_no__sord,exp_lev,item_code__ord,item_code,lot_no,lot_sl,quantity__ord,quantity,loc_code,status,conv__qty_stduom,"
+" unit__std,unit,quantity__stduom,quantity_real,rate__stduom,invoice_id,quantity_inv,pack_instr,no_art,site_code,pack_qty,gross_weight,tare_weight,nett_weight,mfg_date,exp_date,"
+" chg_date,chg_user,chg_term,site_code__mfg,rate__clg,dimension,tax_amt,disc_amt,conf_diff_amt,rate__std,cost_rate,frequency,down_payment,down_payment_int,inst_amount,inst_int_amount,"
+" no_of_inst,line_type,conv__rtuom_stduom,pallet_wt,cust_item__ref,tran_id__invpack,retest_date,part_no,disc_schem_billback_amt,disc_schem_offinv_amt,sscc_18,pack_code,pallet_no) "
+" select desp_id,"+maxLine+",sord_no,line_no__sord,exp_lev,item_code__ord,item_code,'"+lotNoTo+"','"+lotSlTo+"',"+quantity+","+quantity+",'"+locCodeTo+"',status,conv__qty_stduom,unit__std,unit,"+quantity+",quantity_real,rate__stduom,"
+" invoice_id,quantity_inv,pack_instr,no_art,site_code,pack_qty,gross_weight,tare_weight,nett_weight,mfg_date,exp_date,chg_date,chg_user,chg_term,site_code__mfg,rate__clg,dimension,"
+" tax_amt,disc_amt,conf_diff_amt,rate__std,cost_rate,frequency,down_payment,down_payment_int,inst_amount,inst_int_amount,no_of_inst,line_type,conv__rtuom_stduom,pallet_wt,cust_item__ref,"
+" tran_id__invpack,retest_date,part_no,disc_schem_billback_amt,disc_schem_offinv_amt,sscc_18,pack_code,pallet_no "
+" from despatchdet where desp_id = ? and line_no = ? ";
System.out.println("insert qry="+sql);
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,refId);
pstmt1.setInt(2,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row inserted despatchdet ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else
{
sql = " update despatchdet set loc_code = ? ,lot_no = ? ,lot_sl = ? where desp_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,refId);
pstmt1.setInt(5,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated despatchdet ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else if("XFRX".equalsIgnoreCase(refSer.trim())) // Stock Transfer Multiple
{
System.out.println("update for Stock Transfer Multiple");
maxLine = 0;
System.out.println("update... "+quantity+" "+splitQty);
if(splitQty > 0)//insert new record for split quantity
{
sql = " update stock_transfer_det set loc_code__to = ? ,lot_no__to = ? , lot_sl__to = ? ,quantity = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeFr);
pstmt1.setString(2,lotNoFr);
pstmt1.setString(3,lotSlFr);
pstmt1.setDouble(4,splitQty);
pstmt1.setString(5,refId);
pstmt1.setInt(6,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated stock_transfer_det ="+k);
pstmt1.close();
pstmt1 = null;
if(k > 0)
{
sql = " select max(line_no) from stock_transfer_det where tran_id = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
maxLine = rs2.getInt(1);
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
maxLine++;
sql = " insert into stock_transfer_det (tran_id,line_no,item_code,quantity,loc_code__fr,loc_code__to,lot_no__fr,lot_no__to,lot_sl__fr,lot_sl__to,"
+" remarks,acct_code__cr,acct_code__dr,cctr_code__dr,cctr_code__cr,no_art,loc_code__sys) "
+" select tran_id,"+maxLine+",item_code,"+quantity+",'"+locCodeTo+"',loc_code__to,'"+lotNoTo+"',lot_no__to,'"+lotSlTo+"',lot_sl__to, "
+" remarks,acct_code__cr,acct_code__dr,cctr_code__dr,cctr_code__cr,no_art,loc_code__sys from stock_transfer_det where tran_id = ? and line_no = ? ";
System.out.println("insert qry="+sql);
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,refId);
pstmt1.setInt(2,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row inserted stock_transfer_det ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else
{
sql = " update stock_transfer_det set loc_code__to = ? ,lot_no__to = ? , lot_sl__to = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,refId);
pstmt1.setInt(5,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated stock_transfer_det ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else if("C-ISS".equalsIgnoreCase(refSer.trim())) // Consumption Issue(CISS).
{
System.out.println("update for Consumption Issue");
maxLine = 0;
rate = 0;
sql = " select rate from consume_iss_det where cons_issue = ? and line_no = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
pstmt2.setInt(2, refLine);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
rate = rs2.getDouble("rate");
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
System.out.println("update... "+rate+" "+quantity+" "+splitQty);
if(splitQty > 0)//insert new record for split quantity
{
sql = " update consume_iss_det set loc_code = ?,lot_no = ?,lot_sl = ? ,quantity = ? ,quantity__std = ? ,amount = ? where cons_issue = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeFr);
pstmt1.setString(2,lotNoFr);
pstmt1.setString(3,lotSlFr);
pstmt1.setDouble(4,splitQty);
pstmt1.setDouble(5,splitQty);
pstmt1.setDouble(6,splitQty*rate);
pstmt1.setString(7,refId);
pstmt1.setInt(8,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated consume_iss_det ="+k);
pstmt1.close();
pstmt1 = null;
if(k > 0)
{
sql = " select max( line_no) from consume_iss_det where cons_issue = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
maxLine = rs2.getInt(1);
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
maxLine++;
sql = " insert into consume_iss_det (cons_issue,line_no,cons_order,line_no__ord,item_code,quantity,unit,rate,amount,tax_class,tax_chap,tax_env,tax_amt,net_amt,"
+" acct_code,cctr_code,loc_code,lot_no,lot_sl,quantity__std,unit__std,conv_qty_stduom,qc_reqd,acct_code__inv,cctr_code__inv,no_art,anal_code,carton_no,pallet_no) "
+" select cons_issue,"+maxLine+",cons_order,line_no__ord,item_code,"+quantity+",unit,rate,"+rate*quantity+",tax_class,tax_chap,tax_env,tax_amt,net_amt,acct_code,"
+" cctr_code,'"+locCodeTo+"','"+lotNoTo+"','"+lotSlTo+"',"+quantity+",unit__std,conv_qty_stduom,qc_reqd,acct_code__inv,cctr_code__inv,no_art,anal_code,carton_no,pallet_no "
+" from consume_iss_det where CONS_ISSUE = ? and line_no = ? ";
System.out.println("insert qry="+sql);
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,refId);
pstmt1.setInt(2,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row inserted consume_iss_det ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else
{
sql = " update consume_iss_det set loc_code = ?,lot_no = ?,lot_sl = ? where cons_issue = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,refId);
pstmt1.setInt(5,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated consume_iss_det ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else if("ADJISS".equalsIgnoreCase(refSer.trim())) // Adjustment Issue(ADJISS).
{
System.out.println("update for Adjustment Issue");
rate = 0;
maxLine = 0;
sql = " select rate from adj_issrcpdet where tran_id = ? and line_no = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
pstmt2.setInt(2, refLine);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
rate = rs2.getDouble("rate");
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
System.out.println("1420 "+rate+" "+quantity+" "+splitQty);
if(splitQty > 0)//insert new record for split quantity
{
sql = " update adj_issrcpdet set loc_code = ? ,lot_no = ? ,lot_sl = ? ,quantity = ? , amount = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeFr);
pstmt1.setString(2,lotNoFr);
pstmt1.setString(3,lotSlFr);
pstmt1.setDouble(4,splitQty);
pstmt1.setDouble(5,rate * splitQty);
pstmt1.setString(6,refId);
pstmt1.setInt(7,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated adj_issrcpdet ="+k);
pstmt1.close();
pstmt1 = null;
if(k > 0)
{
sql = " select max(line_no) from adj_issrcpdet where tran_id = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
maxLine = rs2.getInt(1);
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
maxLine++;
sql = " insert into adj_issrcpdet (tran_id,line_no,item_code,unit,loc_code,lot_no,lot_sl,quantity,sundry_type,sundry_code,rate,gross_rate,grade,dimension,no_art, "
+" amount,gross_weight,tare_weight,net_weight,acct_code__dr,cctr_code__dr,acct_code__cr,cctr_code__cr,potency_perc,pack_code,mfg_date,exp_date, "
+" site_code__mfg,conv__qty_stduom,unit__alt,conv_qty_stduom,unit_alt,theoretical_wt,retest_date,supp_code__mfg,batch_no) "
+" select tran_id,"+maxLine+",item_code,unit,'"+locCodeTo+"','"+lotNoTo+"','"+lotSlTo+"', "+quantity+", sundry_type,sundry_code,rate,gross_rate,grade,dimension,no_art, "
+ rate * quantity +",gross_weight,tare_weight,net_weight,acct_code__dr,cctr_code__dr,acct_code__cr,cctr_code__cr,potency_perc,pack_code,mfg_date,exp_date, "
+" site_code__mfg,conv__qty_stduom,unit__alt,conv_qty_stduom,unit_alt,theoretical_wt,retest_date,supp_code__mfg,batch_no from adj_issrcpdet "
+" where tran_id = ? and line_no = ? ";
System.out.println("insert qry="+sql);
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,refId);
pstmt1.setInt(2,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row inserted adj_issrcpdet ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else
{
sql = " update adj_issrcpdet set loc_code = ? ,lot_no = ? ,lot_sl = ? ,quantity = ? , amount = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setDouble(4,quantity);
pstmt1.setDouble(5,rate * quantity);
pstmt1.setString(6,refId);
pstmt1.setInt(7,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated adj_issrcpdet ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else if("P-RET".equalsIgnoreCase(refSer.trim())) // Purchase Order Return(PRETURN).
{
System.out.println("update for PRETURN");
rate = 0;
maxLine = 0;
sql = " select rate from porcpdet where tran_id = ? and line_no = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
pstmt2.setInt(2, refLine);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
rate = rs2.getDouble("rate");
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
System.out.println("update.. "+rate+" "+quantity+" "+splitQty);
if(splitQty > 0)//insert new record for split quantity
{
sql = " update porcpdet set loc_code = ? ,lot_no = ? ,lot_sl = ? ,quantity = ?, quantity__stduom = ?,net_amt = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeFr);
pstmt1.setString(2,lotNoFr);
pstmt1.setString(3,lotSlFr);
pstmt1.setDouble(4,splitQty);
pstmt1.setDouble(5,splitQty);
pstmt1.setDouble(6,rate * splitQty);
pstmt1.setString(7,refId);
pstmt1.setInt(8,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated porcpdet ="+k);
pstmt1.close();
pstmt1 = null;
if(k > 0)
{
sql = " select max(line_no) from porcpdet where tran_id = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
maxLine = rs2.getInt(1);
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
maxLine++;
sql = " insert into porcpdet (tran_id,line_no,item_code,purc_order,quantity,unit,rate,discount,tax_amt,net_amt,loc_code,lot_no,lot_sl,line_no__ord,"
+" canc_bo,vouch_qty,acct_code__dr,cctr_code__dr,acct_code__cr,cctr_code__cr,unit__rate,conv__qty_stduom,conv__rtuom_stduom,unit__std,"
+" quantity__stduom,rate__stduom,pack_code,no_art,pack_instr,batch_no,mfg_date,expiry_date,gross_weight,tare_weight,net_weight,status,"
+" potency_perc,supp_code__mnfr,site_code__mfg,reas_code,remarks,challan_qty,grade,tax_class,tax_chap,tax_env,specific_instr,special_instr,"
+" loc_code__excess_short,excess_short_qty,additional_cost,rate__clg,supp_challan_qty,realised_qty,item_code__mfg,spec_ref,std_rate,dept_code,"
+" effect_stock,physical_status,benefit_type,licence_no,acct_code__prov_dr,cctr_code__prov_dr,acct_code__prov_cr,cctr_code__prov_cr,form_no,"
+" retest_date,duty_paid,batch_size,damage_qty,sample_qty,shelf_life__type,qc_reqd,sh_qty,rejc_qty,assetinstall_qty,part_qty,partial_yn,anal_code,carton_no,pallet_no) "
+" select tran_id,"+maxLine+",item_code,purc_order,"+quantity+",unit,rate,discount,tax_amt,"+quantity*rate+",'"+locCodeTo+"','"+lotNoTo+"','"+lotSlTo+"',line_no__ord,"
+" canc_bo,vouch_qty,acct_code__dr,cctr_code__dr,acct_code__cr,cctr_code__cr,unit__rate,conv__qty_stduom,conv__rtuom_stduom,unit__std, "
+ quantity+",rate__stduom,pack_code,no_art,pack_instr,batch_no,mfg_date,expiry_date,gross_weight,tare_weight,net_weight,status,potency_perc,supp_code__mnfr,"
+" site_code__mfg,reas_code,remarks,challan_qty,grade,tax_class,tax_chap,tax_env,specific_instr,special_instr,loc_code__excess_short,excess_short_qty,"
+" additional_cost,rate__clg,supp_challan_qty,realised_qty,item_code__mfg,spec_ref,std_rate,dept_code,effect_stock,physical_status,benefit_type,licence_no,"
+" acct_code__prov_dr,cctr_code__prov_dr,acct_code__prov_cr,cctr_code__prov_cr,form_no,retest_date,duty_paid,batch_size,damage_qty,sample_qty,shelf_life__type,"
+" qc_reqd,sh_qty,rejc_qty,assetinstall_qty,part_qty,partial_yn,anal_code,carton_no,pallet_no from porcpdet where tran_id = ? and line_no = ? ";
System.out.println("insert qry="+sql);
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,refId);
pstmt1.setInt(2,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row inserted porcpdet ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else
{
sql = " update porcpdet set loc_code = ? ,lot_no = ? ,lot_sl = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,refId);
pstmt1.setInt(5,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated porcpdet ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else if("R-BFS".equalsIgnoreCase(refSer.trim())) // Receipt Back Flush
{
System.out.println("update for Receipt Back Flush");
rate = 0;
maxLine = 0;
sql = " select rate from receipt_backflush_det where tran_id = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
pstmt2.setInt(2, refLine);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
rate = rs2.getDouble("rate");
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
System.out.println("update.. "+rate+" "+quantity+" "+splitQty);
if(splitQty > 0)//insert new record for split quantity
{
sql = " update receipt_backflush_det set loc_code = ? ,lot_no = ? ,lot_sl = ? ,quantity = ?,amount = ?,net_amt = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeFr);
pstmt1.setString(2,lotNoFr);
pstmt1.setString(3,lotSlFr);
pstmt1.setDouble(4,splitQty);
pstmt1.setDouble(5,rate * splitQty);
pstmt1.setDouble(6,rate * splitQty);
pstmt1.setString(7,refId);
pstmt1.setInt(8,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated receipt_backflush_det ="+k);
pstmt1.close();
pstmt1 = null;
if(k > 0)
{
sql = " select select max(line_no) from receipt_backflush_det where tran_id = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
maxLine = rs2.getInt(1);
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
maxLine++;
sql = " insert into receipt_backflush_det (tran_id,line_no,site_code,loc_code,lot_no,lot_sl,item_code,"
+" ref_no,quantity,rate,amount,tax_amt,discount,net_amt,unit,unit__doc,conv_qty_doc,qty_doc,rate_doc,no_art) "
+" select tran_id,"+maxLine+",site_code,'"+locCodeTo+"','"+lotNoTo+"','"+lotSlTo+"',item_code,ref_no,"+quantity+",rate,"+quantity*rate+",tax_amt,"
+" discount," +quantity*rate+",unit,unit__doc,conv_qty_doc,qty_doc,rate_doc,no_art from receipt_backflush_det where tran_id = ? and line_no = ? ";
System.out.println("insert qry="+sql);
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,refId);
pstmt1.setInt(2,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row inserted receipt_backflush_det ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else
{
sql = " update receipt_backflush_det set loc_code = ? ,lot_no = ? ,lot_sl = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,refId);
pstmt1.setInt(5,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated receipt_backflush_det ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else if("S-RET".equalsIgnoreCase(refSer.trim())) // (Sales Return)SRETURN.
{
System.out.println("update for SRETURN.");
rate = 0;
maxLine = 0;
sql = " select rate from receipt_backflush_det where tran_id = ? and line_no = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
pstmt2.setInt(2, refLine);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
rate = rs2.getDouble("rate");
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
System.out.println("update... "+rate+" "+quantity+" "+splitQty);
if(splitQty > 0)//insert new record for split quantity
{
sql = " update sreturndet set loc_code = ? ,lot_no = ? ,lot_sl = ? ,quantity = ?,quantity__stduom = ?,net_amt = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeFr);
pstmt1.setString(2,lotNoFr);
pstmt1.setString(3,lotSlFr);
pstmt1.setDouble(4,splitQty);
pstmt1.setDouble(5,rate * splitQty);
pstmt1.setDouble(6,rate * splitQty);
pstmt1.setString(7,refId);
pstmt1.setInt(8,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated sreturndet ="+k);
pstmt1.close();
pstmt1 = null;
if(k > 0)
{
sql = " select max(line_no) from sreturndet where tran_id = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, refId);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
maxLine = rs2.getInt(1);
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
maxLine++;
sql = " insert into sreturndet (tran_id,line_no,invoice_id,line_no__inv,item_code,quantity,net_amt,status,"
+" reas_code,loc_code,stk_opt,rate,lot_no,lot_sl,tax_class,tax_chap,tax_env,unit,chg_date,chg_user,chg_term,"
+" ret_rep_flag,eff_net_amt,conv__qty_stduom,conv__rtuom_stduom,unit__std,quantity__stduom,rate__stduom,exp_date,discount,tax_amt,"
+" site_code__mfg,mfg_date,unit__rate,pack_code,full_ret,item_ser,reas_code__org,no_art,rate__clg,rate__stk,cost_rate,"
+" expiry_deduction,rate__std,claim_qty,physical_qty,rate_std,qc_reqd,line_no__invtrace,mrp_value,sale_order,physical_status,line_type,"
+" invoice_id__club,part_qty,cust_item__ref,gross_weight,tare_weight,net_weight,cust_item__code,sord_line_no,contract_no,line_no__sform) "
+" select tran_id,"+maxLine+",invoice_id,line_no__inv,item_code,"+quantity+","+quantity * rate+",status,reas_code,'"+locCodeTo+"',stk_opt,"
+" rate,'"+lotNoTo+"','"+lotSlTo+"',tax_class,tax_chap,tax_env,unit,chg_date,chg_user,chg_term,ret_rep_flag,eff_net_amt,conv__qty_stduom,"
+" conv__rtuom_stduom,unit__std,"+quantity+",rate__stduom,exp_date,discount,tax_amt,site_code__mfg,mfg_date,unit__rate,pack_code,full_ret,"
+" item_ser,reas_code__org,no_art,rate__clg,rate__stk,cost_rate,expiry_deduction,rate__std,claim_qty,physical_qty,rate_std,qc_reqd,"
+" line_no__invtrace,mrp_value,sale_order,physical_status,line_type,invoice_id__club,part_qty,cust_item__ref,gross_weight,tare_weight,"
+" net_weight,cust_item__code,sord_line_no,contract_no,line_no__sform from sreturndet where tran_id = ? and line_no = ? ";
System.out.println("insert qry="+sql);
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,refId);
pstmt1.setInt(2,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row inserted adj_issrcpdet ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else
{
sql = " update sreturndet set loc_code = ? ,lot_no = ? ,lot_sl = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,refId);
pstmt1.setInt(5,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated sreturndet ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else if("W-ISS".equalsIgnoreCase(refSer.trim())) // Work order ISS .
{
sql = " update workorder_issdet set loc_code = ? ,lot_no = ? ,lot_sl = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,refId);
pstmt1.setInt(5,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated workorder_issdet ="+k);
pstmt1.close();
pstmt1 = null;
}
else if("S-ALC".equalsIgnoreCase(refSer.trim())) // Manual Sorder Allocation
{
System.out.println("update for Manual Sorder Allocation");
System.out.println("update.. "+quantity+" "+splitQty);
if(splitQty > 0)//insert new record for split quantity
{
sql = " update sordalloc set loc_code = ? ,lot_no = ? ,lot_sl = ? , quantity = ?,quantity__stduom = ? where sale_order = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeFr);
pstmt1.setString(2,lotNoFr);
pstmt1.setString(3,lotSlFr);
pstmt1.setDouble(4,splitQty);
pstmt1.setDouble(5,splitQty);
pstmt1.setString(6,refId);
pstmt1.setInt(7,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated sordalloc ="+k);
pstmt1.close();
pstmt1 = null;
if(k > 0)
{
sql = " insert into sordalloc (sale_order,line_no,exp_lev,item_code__ord,item_code,lot_no,lot_sl,loc_code,item_ref,quantity,unit,qty_alloc,"
+" date_alloc,status,item_grade,exp_date,alloc_mode,site_code,conv__qty_stduom,unit__std,quantity__stduom,mfg_date,site_code__mfg,reas_code,ref_id__alloc,ref_line__no,wave_flag) "
+" select sale_order,line_no,exp_lev,item_code__ord,item_code,'"+lotNoTo+"','"+lotSlTo+"','"+locCodeTo+"',item_ref,"+quantity+",unit,qty_alloc,date_alloc,"
+" status,item_grade,exp_date,alloc_mode,site_code,conv__qty_stduom,unit__std,"+quantity+",mfg_date,site_code__mfg,reas_code,"
+" ref_id__alloc,ref_line__no,wave_flag from sordalloc where SALE_ORDER = ? and LINE_NO = ? "
+" and site_code = ? and loc_code = ? and item_code = ? and lot_no = ? and lot_sl = ? ";
System.out.println("insert qry="+sql);
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,refId);
pstmt1.setInt(2,refLine);
pstmt1.setString(3,siteCode);
pstmt1.setString(4,locCodeFr);
pstmt1.setString(5,itemCode);
pstmt1.setString(6,lotNoFr);
pstmt1.setString(7,lotSlFr);
k = pstmt1.executeUpdate();
System.out.println("No of row inserted adj_issrcpdet ="+k);
pstmt1.close();
pstmt1 = null;
}
}
else
{
sql = " update sordalloc set loc_code = ? ,lot_no = ? ,lot_sl = ? where sale_order = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,refId);
pstmt1.setInt(5,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated sordalloc ="+k);
pstmt1.close();
pstmt1 = null;
}
}
}
}while(rs.next());
//end rs loop
}
}
}
rs.close();
rs = null;
if(pstmt != null)
pstmt.close();
pstmt = null;
if(stmt != null)
stmt.close();
stmt = null;
if(conn != null)
conn.commit();
System.out.println("after invtracealloc check .. pendingQty =="+pendingQty+" quantitydet="+quantitydet);
quantitydet = pendingQty;
if(pendingQty > 0)
{
if(checkWOIssue)//if qty alloc in work order
{
stockQty = 0;
System.out.println("qty alloc in work order ");
sql = " select inv_allocate.work_order ,inv_alloc_det.tran_id, inv_alloc_det.line_no ,inv_alloc_det.alloc_qty from inv_allocate , inv_alloc_det where inv_allocate.tran_id = inv_alloc_det.tran_id "
+" and case when inv_alloc_det.deallocated is null then 'N' else inv_alloc_det.deallocated end != 'Y' "
+" and inv_alloc_det.site_code = ? and inv_alloc_det.loc_code = ? and inv_alloc_det.item_code = ? "
+" and inv_alloc_det.lot_no = ? and inv_alloc_det.lot_sl = ? order by inv_alloc_det.alloc_qty desc " ;
pstmt = conn.prepareStatement(sql,ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY,ResultSet.HOLD_CURSORS_OVER_COMMIT);
pstmt.setString(1, siteCode);
pstmt.setString(2, locCodeFr);
pstmt.setString(3, itemCode);
pstmt.setString(4, lotNoFr);
pstmt.setString(5, lotSlFr);
rs = pstmt.executeQuery();
while(rs.next())
{
refId = checkNull(rs.getString( "tran_id" ));
//refLine = rs.getInt("ref_line");
refLine = Integer.parseInt( checkNull(rs.getString("line_no")).trim().length() == 0 ?"0":rs.getString("line_no").trim()) ;
refQty = rs.getDouble("alloc_qty");
workorder = rs.getString("work_order");
System.out.println("pendingQty="+pendingQty);
System.out.println("refSer="+refSer);
System.out.println("refId="+refId);
System.out.println("refLine="+refLine);
System.out.println("refQty="+refQty);
if(pendingQty <= 0)
{
break;
}
if(pendingQty <= refQty)
{
quantity = pendingQty;
pendingQty = 0;
}
else
{
quantity = refQty;
pendingQty = pendingQty - refQty ;
}
stockQty = stockQty + quantity;
sql = " select workorder_issdet.tran_id ,workorder_issdet.line_no from workorder_iss , workorder_issdet where workorder_iss.tran_id = workorder_issdet.tran_id "
+" and workorder_iss.work_order = ? and workorder_iss.site_code = ? "
+" and workorder_issdet.loc_code = ? and workorder_issdet.item_code = ? and workorder_issdet.lot_no = ? and workorder_issdet.lot_sl = ? ";
pstmt1 = conn.prepareStatement(sql);
pstmt1.setString(1, workorder);
pstmt1.setString(2, siteCode);
pstmt1.setString(3, locCodeFr);
pstmt1.setString(4, itemCode);
pstmt1.setString(5, lotNoFr);
pstmt1.setString(6, lotSlFr);
rs1 = pstmt1.executeQuery();
while(rs1.next())
{
tranId = rs1.getString("tran_id");
lineNo = rs1.getInt("line_no");
sql = " select count(*) from workorder_issdet_sl where tran_id = ? ";
pstmt2 = conn.prepareStatement(sql);
pstmt2.setString(1, tranId);
rs2 = pstmt2.executeQuery();
if(rs2.next())
{
count = rs2.getInt(1);
}
rs2.close();
rs2 = null;
pstmt2.close();
pstmt2 = null;
if(count > 0) //if weighing is done then give error
{
retValue.add("Error");
retValue.add(new Double(quantitydet));
return retValue;
}
}
rs1.close();
rs1 = null;
pstmt1.close();
pstmt1 = null;
hashMap = new HashMap();
// hashMap.put("tran_date",new java.sql.Date(System.currentTimeMillis()));
hashMap.put("tran_date",tranDate);
hashMap.put("ref_ser","W-ISS");
hashMap.put("ref_id",refId);
hashMap.put("ref_line",String.valueOf(refLine));
hashMap.put("site_code",siteCode);
hashMap.put("item_code",itemCode);
hashMap.put("loc_code",locCodeFr);
hashMap.put("lot_no",lotNoFr);
hashMap.put("lot_sl",lotSlFr);
hashMap.put("alloc_qty",new Double(-1*quantity));
hashMap.put("chg_user",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"loginCode"));
hashMap.put("chg_term",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"termId"));
errString = invAllocTrace.updateInvallocTrace(hashMap, conn);
System.out.println("updateInvallocTrace....."+errString);
if(errString != null && errString.trim().length() > 0)
{
retValue.add("Error");
retValue.add(new Double(quantitydet));
return retValue;
}
}//rs loop end
System.out.println("Stock Qty="+stockQty+" pendingQty="+pendingQty);
if (stockQty > 0 && ( errString == null || errString.trim().length() == 0))
{
stockMap = tempMap;
stockMap.put("loc_code", locCodeFr);
stockMap.put("lot_no", lotNoFr);
stockMap.put("lot_sl", lotSlFr);
stockMap.put("tran_type", "I");
stockMap.put("quantity", ""+stockQty);
stockMap.put("qty_stduom", ""+stockQty);
//stock update for tran type = "I"
errString = stkUpdate.updateStock( stockMap, xtraParams, conn ); //updateStock called only once's
System.out.println("stock update FOR I ....."+errString);
if ( errString != null && errString.trim().length() > 0 )
{
retValue.add("Error");
retValue.add(new Double(quantitydet));
return retValue;
}
else
{
stockMap.put("loc_code", locCodeTo);
stockMap.put("lot_no", lotNoTo);
stockMap.put("lot_sl", lotSlTo);
stockMap.put("tran_type", "R");
//stock update for tran type = "R"
errString = stkUpdate.updateStock( stockMap, xtraParams, conn ); //updateStock called only once's
System.out.println("stock update FOR R ....."+errString);
if ( errString != null && errString.trim().length() > 0 )
{
retValue.add("Error");
retValue.add(new Double(quantitydet));
return retValue;
}
}
if ( errString == null || errString.trim().length() == 0)
{
if(rs != null)
{
rs.first();
pendingQty = quantitydet;
System.out.println("iterate rs for deallcation ");
do
{
refId = checkNull(rs.getString( "tran_id" ));
//refLine = rs.getInt("ref_line");
refLine = Integer.parseInt( checkNull(rs.getString("line_no")).trim().length() == 0 ?"0":rs.getString("line_no").trim()) ;
refQty = rs.getDouble("alloc_qty");
workorder = rs.getString("work_order");
System.out.println("pendingQty="+pendingQty);
System.out.println("refSer="+refSer);
System.out.println("refId="+refId);
System.out.println("refLine="+refLine);
System.out.println("refQty="+refQty);
if(pendingQty <= 0)
{
break;
}
if(pendingQty <= refQty)
{
quantity = pendingQty;
pendingQty = 0;
}
else
{
quantity = refQty;
pendingQty = pendingQty - refQty ;
}
hashMap = new HashMap();
// hashMap.put("tran_date",new java.sql.Date(System.currentTimeMillis()));
hashMap.put("tran_date",tranDate);
hashMap.put("ref_ser",refSer);
hashMap.put("ref_id",refId);
hashMap.put("ref_line",String.valueOf(refLine));
hashMap.put("site_code",siteCode);
hashMap.put("item_code",itemCode);
hashMap.put("loc_code",locCodeTo);
hashMap.put("lot_no",lotNoTo);
hashMap.put("lot_sl",lotSlTo);
hashMap.put("alloc_qty",new Double(quantity));
hashMap.put("chg_user",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"loginCode"));
hashMap.put("chg_term",GenericUtility.getInstance().getValueFromXTRA_PARAMS(xtraParams,"termId"));
errString = invAllocTrace.updateInvallocTrace(hashMap, conn);
System.out.println("updateInvallocTrace 2....."+errString);
if ( errString != null && errString.trim().length() > 0 )
{
retValue.add("Error");
retValue.add(new Double(quantitydet));
return retValue;
}
else
{
sql = " update inv_alloc_det set loc_code = ? ,lot_no = ? ,lot_sl = ? where tran_id = ? and line_no = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,refId);
pstmt1.setInt(5,refLine);
k = pstmt1.executeUpdate();
System.out.println("No of row updated inv_alloc_det ="+k);
pstmt1.close();
pstmt1 = null;
sql = " update workorder_issdet set loc_code = ? ,lot_no = ? ,lot_sl = ? where tran_id in (select tran_id from workorder_iss where work_order = ? and site_code = ? ) "
+" and loc_code = ? and item_code = ? and lot_no = ? and lot_sl = ? ";
pstmt1 =conn.prepareStatement(sql);
pstmt1.setString(1,locCodeTo);
pstmt1.setString(2,lotNoTo);
pstmt1.setString(3,lotSlTo);
pstmt1.setString(4,workorder);
pstmt1.setString(5,siteCode);
pstmt1.setString(6,locCodeFr);
pstmt1.setString(7,itemCode);
pstmt1.setString(8,locCodeFr);
pstmt1.setString(9,lotSlFr);
k = pstmt1.executeUpdate();
System.out.println("No of row updated workorder_issdet ="+k);
pstmt1.close();
pstmt1 = null;
}
}while(rs.next()); //rs 2nd lopp end
rs.close();
rs = null;
pstmt.close();
pstmt = null;
if(conn != null)
conn.commit();
}
}
}
quantitydet = pendingQty;
}//check for work order alloc qty
}//check pending qty
} catch (SQLException e)
{
System.out.println("SQLException :allocDeAlloc :SQLException :==>\n"+e.getMessage());
errString = e.getMessage();
e.printStackTrace();
throw new ITMException(e);
}
catch (Exception e)
{
System.out.println("Exception :allocDeAlloc : :Exception :==>\n"+e.getMessage());
errString = e.getMessage();
e.printStackTrace();
throw new ITMException(e);
}
System.out.println("Befor Map");
System.out.println("err string::"+errString);
System.out.println("pending qty::"+quantitydet);
System.out.println("Befor Map");
retValue.add(errString);
retValue.add(new Double(quantitydet));
return retValue;
}//end allocTransfer
} }
\ No newline at end of file
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment