midsuit
/
core-jgi
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Test reverting revisions 5291 & 5292 in sqlj - the way it was integrated deleted all history on the modified classes

This commit is contained in:
Carlos Ruiz 2008-05-30 03:28:45 +00:00
parent 8afa3568d2
commit 1c60b5fdb4
2 changed files with 839 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

367
sqlj/src/org/compiere/sqlj/Invoice.java Normal file
View File

@ -0,0 +1,367 @@
/******************************************************************************
* Product: Adempiere ERP & CRM Smart Business Solution *
* Copyright (C) 1999-2006 ComPiere, Inc. All Rights Reserved. *
* This program is free software; you can redistribute it and/or modify it *
* under the terms version 2 of the GNU General Public License as published *
* by the Free Software Foundation. This program is distributed in the hope *
* that it will be useful, but WITHOUT ANY WARRANTY; without even the implied *
* warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. *
* See the GNU General Public License for more details. *
* You should have received a copy of the GNU General Public License along *
* with this program; if not, write to the Free Software Foundation, Inc., *
* 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. *
* For the text or an alternative of this public license, you may reach us *
* ComPiere, Inc., 2620 Augustine Dr. #245, Santa Clara, CA 95054, USA *
* or via info@compiere.org or http://www.compiere.org/license.html *
*****************************************************************************/
package org.compiere.sqlj;
import java.math.*;
import java.sql.*;
/**
* SQLJ Invoice related Functions
*
* @author Jorg Janke
* @version $Id: Invoice.java,v 1.3 2006/07/30 00:59:07 jjanke Exp $
*/
public class Invoice
{
/**
* Open Invoice Amount.
* - incoiceOpen
* @param p_C_Invoice_ID invoice
* @param p_C_InvoicePaySchedule_ID payment schedule
* @return open amount
* @throws SQLException
*/
public static BigDecimal open (int p_C_Invoice_ID, int p_C_InvoicePaySchedule_ID)
throws SQLException
{
// Invoice info
int C_Currency_ID = 0;
int C_ConversionType_ID = 0;
BigDecimal GrandTotal = null;
BigDecimal MultiplierAP = null;
BigDecimal MultiplierCM = null;
//
String sql = "SELECT MAX(C_Currency_ID),MAX(C_ConversionType_ID),"
+ " SUM(GrandTotal), MAX(MultiplierAP), MAX(Multiplier) "
+ "FROM C_Invoice_v " // corrected for CM / Split Payment
+ "WHERE C_Invoice_ID=?";
if (p_C_InvoicePaySchedule_ID != 0)
sql += " AND C_InvoicePaySchedule_ID=?";
PreparedStatement pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_C_Invoice_ID);
if (p_C_InvoicePaySchedule_ID != 0)
pstmt.setInt(2, p_C_InvoicePaySchedule_ID);
ResultSet rs = pstmt.executeQuery();
if (rs.next())
{
C_Currency_ID = rs.getInt(1);
C_ConversionType_ID = rs.getInt(2);
GrandTotal = rs.getBigDecimal(3);
MultiplierAP = rs.getBigDecimal(4);
MultiplierCM = rs.getBigDecimal(5);
}
rs.close();
pstmt.close();
// No Invoice
if (GrandTotal == null)
return null;
BigDecimal paidAmt = allocatedAmt(p_C_Invoice_ID, C_Currency_ID,
C_ConversionType_ID, MultiplierAP);
BigDecimal TotalOpenAmt = GrandTotal.subtract(paidAmt);
/**
GrandTotal Paid TotalOpen Remaining Due x
100 0 100 =0
1a =50-0 50 x
1b =0-50 =0 50
2a =0-50 =0 50
2b =50-0 50 x
--
100 10 100 =10
1a =50-10 50 x
1b =10-50 =0 50
2a =10-50 =0 50
2b =50-0 50 x
--
100 60 100 =60
1a =50-60 =0 50 x
1b =60-50 50
2a =60-50 =10 50
2b =50-10 50 x
--
**/
// Do we have a Payment Schedule ?
if (p_C_InvoicePaySchedule_ID > 0) // if not valid = lists invoice amount
{
TotalOpenAmt = GrandTotal;
BigDecimal remainingAmt = paidAmt;
sql = "SELECT C_InvoicePaySchedule_ID, DueAmt "
+ "FROM C_InvoicePaySchedule "
+ "WHERE C_Invoice_ID=?"
+ " AND IsValid='Y' "
+ "ORDER BY DueDate";
pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_C_Invoice_ID);
rs = pstmt.executeQuery();
while (rs.next())
{
int C_InvoicePaySchedule_ID = rs.getInt(1);
BigDecimal DueAmt = rs.getBigDecimal(2);
//
if (C_InvoicePaySchedule_ID == p_C_InvoicePaySchedule_ID)
{
if (DueAmt.signum() > 0) // positive
{
if (DueAmt.compareTo(remainingAmt) < 0) // paid more
TotalOpenAmt = Adempiere.ZERO;
else
TotalOpenAmt = DueAmt.multiply(MultiplierCM)
.subtract(remainingAmt);
}
else
{
if (DueAmt.compareTo(remainingAmt) > 0) // paid more
TotalOpenAmt = Adempiere.ZERO;
else
TotalOpenAmt = DueAmt.multiply(MultiplierCM)
.add(remainingAmt);
}
}
else
{
if (DueAmt.signum() > 0) // positive
{
remainingAmt = remainingAmt.subtract(DueAmt);
if (remainingAmt.signum() < 0)
remainingAmt = Adempiere.ZERO;
}
else
{
remainingAmt = remainingAmt.add(DueAmt);
if (remainingAmt.signum() < 0)
remainingAmt = Adempiere.ZERO;
}
}
}
rs.close();
pstmt.close();
} // Invoice Schedule
// Rounding
TotalOpenAmt = Currency.round(TotalOpenAmt, C_Currency_ID, null);
// Ignore Penny if there is a payment
if (paidAmt.signum() != 0)
{
double open = TotalOpenAmt.doubleValue();
if (open >= -0.01 && open <= 0.01)
TotalOpenAmt = Adempiere.ZERO;
}
//
return TotalOpenAmt;
} // open
/**
* Get Invoice paid(allocated) amount.
* - invoicePaid
* @param p_C_Invoice_ID invoice
* @param p_C_Currency_ID currency
* @param p_MultiplierAP multiplier
* @return paid amount
* @throws SQLException
*/
public static BigDecimal paid (int p_C_Invoice_ID, int p_C_Currency_ID, int p_MultiplierAP)
throws SQLException
{
// Invalid Parameters
if (p_C_Invoice_ID == 0 || p_C_Currency_ID == 0)
return null;
// Parameters
BigDecimal MultiplierAP = new BigDecimal((double)p_MultiplierAP);
if (p_MultiplierAP == 0)
MultiplierAP = Adempiere.ONE;
int C_ConversionType_ID = 0;
// Calculate Allocated Amount
BigDecimal paymentAmt = allocatedAmt(p_C_Invoice_ID,
p_C_Currency_ID, C_ConversionType_ID, MultiplierAP);
return Currency.round(paymentAmt, p_C_Currency_ID, null);
} // paid
/**
* Get Allocated Amt (not directly used)
* @param C_Invoice_ID invoice
* @param C_Currency_ID currency
* @param C_ConversionType_ID conversion type
* @param MultiplierAP multiplier
* @return allocated amount
* @throws SQLException
*/
public static BigDecimal allocatedAmt(int C_Invoice_ID,
int C_Currency_ID, int C_ConversionType_ID, BigDecimal MultiplierAP)
throws SQLException
{
// Calculate Allocated Amount
BigDecimal paidAmt = Adempiere.ZERO;
String sql = "SELECT a.AD_Client_ID, a.AD_Org_ID,"
+ " al.Amount, al.DiscountAmt, al.WriteOffAmt,"
+ " a.C_Currency_ID, a.DateTrx "
+ "FROM C_AllocationLine al"
+ " INNER JOIN C_AllocationHdr a ON (al.C_AllocationHdr_ID=a.C_AllocationHdr_ID) "
+ "WHERE al.C_Invoice_ID=?"
+ " AND a.IsActive='Y'";
PreparedStatement pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, C_Invoice_ID);
ResultSet rs = pstmt.executeQuery();
while (rs.next())
{
int AD_Client_ID = rs.getInt(1);
int AD_Org_ID = rs.getInt(2);
BigDecimal Amount = rs.getBigDecimal(3);
BigDecimal DiscountAmt = rs.getBigDecimal(4);
BigDecimal WriteOffAmt = rs.getBigDecimal(5);
int C_CurrencyFrom_ID = rs.getInt(6);
Timestamp DateTrx = rs.getTimestamp(7);
//
BigDecimal invAmt = Amount.add(DiscountAmt).add(WriteOffAmt);
BigDecimal allocation = Currency.convert(invAmt.multiply(MultiplierAP),
C_CurrencyFrom_ID, C_Currency_ID, DateTrx, C_ConversionType_ID,
AD_Client_ID, AD_Org_ID);
if (allocation != null)
paidAmt = paidAmt.add(allocation);
}
rs.close();
pstmt.close();
//
return paidAmt;
} // getAllocatedAmt
/**
* Get Invoice discount.
* C_Invoice_Discount - invoiceDiscount
* @param p_C_Invoice_ID invoice
* @param p_PayDate pay date
* @param p_C_InvoicePaySchedule_ID pay schedule
* @return discount amount or null
* @throws SQLException
*/
public static BigDecimal discount (int p_C_Invoice_ID,
Timestamp p_PayDate, int p_C_InvoicePaySchedule_ID)
throws SQLException
{
// Parameters
if (p_C_Invoice_ID == 0)
return null;
Timestamp PayDate = p_PayDate;
if (PayDate == null)
PayDate = new Timestamp (System.currentTimeMillis());
PayDate = Adempiere.trunc(PayDate);
// Invoice Info
boolean IsDiscountLineAmt = false;
BigDecimal GrandTotal = null;
BigDecimal TotalLines = null;
int C_PaymentTerm_ID = 0;
Timestamp DateInvoiced = null;
boolean IsPayScheduleValid = false;
int C_Currency_ID = 0;
String sql = "SELECT ci.IsDiscountLineAmt, i.GrandTotal, i.TotalLines, "
+ " i.C_PaymentTerm_ID, i.DateInvoiced, i.IsPayScheduleValid, i.C_Currency_ID "
+ "FROM C_Invoice i"
+ " INNER JOIN AD_ClientInfo ci ON (ci.AD_Client_ID=i.AD_Client_ID) "
+ "WHERE i.C_Invoice_ID=?";
PreparedStatement pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_C_Invoice_ID);
ResultSet rs = pstmt.executeQuery();
if (rs.next())
{
IsDiscountLineAmt = "Y".equals(rs.getString(1));
GrandTotal = rs.getBigDecimal(2);
TotalLines = rs.getBigDecimal(3);
C_PaymentTerm_ID = rs.getInt(4);
DateInvoiced = rs.getTimestamp(5);
IsPayScheduleValid = "Y".equals(rs.getString(6));
C_Currency_ID = rs.getInt(7);
}
rs.close();
pstmt.close();
// Not found
if (GrandTotal == null)
//vpj-cd return null;
return Adempiere.ZERO;
// What Amount is the Discount Base?
BigDecimal amount = GrandTotal;
if (IsDiscountLineAmt)
amount = TotalLines;
// Anything to discount?
if (amount.signum() == 0)
return Adempiere.ZERO;
// Valid Payment Schedule (has discount)
if (IsPayScheduleValid && p_C_InvoicePaySchedule_ID > 0)
{
BigDecimal discount = Adempiere.ZERO;
sql = "SELECT DiscountAmt "
+ "FROM C_InvoicePaySchedule "
+ "WHERE C_InvoicePaySchedule_ID=?"
+ " AND TRUNC(DiscountDate) <= ?";
pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_C_InvoicePaySchedule_ID);
pstmt.setTimestamp(2, PayDate);
rs = pstmt.executeQuery();
if (rs.next())
discount = rs.getBigDecimal(1);
rs.close();
pstmt.close();
//
return discount;
}
// return discount amount
return PaymentTerm.discount (amount, C_Currency_ID,
C_PaymentTerm_ID, DateInvoiced, PayDate);
} // discount
/**
* Test
* @param args
*
public static void main (String[] args)
{
try
{
DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
Adempiere.s_type = Adempiere.TYPE_ORACLE;
Adempiere.s_url = "jdbc:oracle:thin:@//dev1:1521/dev1.adempiere.org";
Adempiere.s_uid = "adempiere";
Adempiere.s_pwd = "adempiere";
// System.out.println(Invoice.open(1000000, 1000004));
// System.out.println(Invoice.open(1000000, 1000005));
// System.out.println(Invoice.open(1000001, 1000006));
// System.out.println(Invoice.open(1000001, 1000007));
System.out.println(Invoice.paid(101, 100, 1));
System.out.println(Invoice.paid(1000000, 100, 1));
System.out.println(Invoice.paid(1000001, 100, 1));
System.out.println(Invoice.paid(1000002, 100, 1));
}
catch (SQLException e)
{
e.printStackTrace();
}
} // main /* */
} // Invoice

472
sqlj/src/org/compiere/sqlj/Product.java Normal file
View File

@ -0,0 +1,472 @@
/******************************************************************************
* Product: Adempiere ERP & CRM Smart Business Solution *
* Copyright (C) 1999-2006 ComPiere, Inc. All Rights Reserved. *
* This program is free software; you can redistribute it and/or modify it *
* under the terms version 2 of the GNU General Public License as published *
* by the Free Software Foundation. This program is distributed in the hope *
* that it will be useful, but WITHOUT ANY WARRANTY; without even the implied *
* warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. *
* See the GNU General Public License for more details. *
* You should have received a copy of the GNU General Public License along *
* with this program; if not, write to the Free Software Foundation, Inc., *
* 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. *
* For the text or an alternative of this public license, you may reach us *
* ComPiere, Inc., 2620 Augustine Dr. #245, Santa Clara, CA 95054, USA *
* or via info@compiere.org or http://www.compiere.org/license.html *
*****************************************************************************/
package org.compiere.sqlj;
import java.math.*;
import java.sql.*;
/**
* SQLJ Product related Functions
*
* @author Jorg Janke
* @version $Id: Product.java,v 1.3 2006/07/30 00:59:07 jjanke Exp $
*/
public class Product
{
/**
* Get Product Attribute Instance Name.
* Previously: M_Attribute_Name - Now: productAttribute
* Test:
SELECT M_Attribute_Name (M_AttributeSetInstance_ID)
FROM M_InOutLine WHERE M_AttributeSetInstance_ID > 0
--
SELECT p.Name
FROM C_InvoiceLine il LEFT OUTER JOIN M_Product p ON (il.M_Product_ID=p.M_Product_ID);
SELECT p.Name || M_Attribute_Name (il.M_AttributeSetInstance_ID)
FROM C_InvoiceLine il LEFT OUTER JOIN M_Product p ON (il.M_Product_ID=p.M_Product_ID);
* @param p_M_AttributeSetInstance_ID instance
* @return Name or ""
* @throws SQLException
*/
public static String attributeName (int p_M_AttributeSetInstance_ID)
throws SQLException
{
if (p_M_AttributeSetInstance_ID == 0)
return "";
//
StringBuffer sb = new StringBuffer();
// Get Base Info
String sql = "SELECT asi.Lot, asi.SerNo, asi.GuaranteeDate "
+ "FROM M_AttributeSetInstance asi "
+ "WHERE asi.M_AttributeSetInstance_ID=?";
PreparedStatement pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_M_AttributeSetInstance_ID);
ResultSet rs = pstmt.executeQuery();
if (rs.next())
{
String lot = rs.getString(1);
if (lot != null && lot.length() > 0)
sb.append(lot).append(" ");
String serNo = rs.getString(2);
if (serNo != null && serNo.length() > 0)
sb.append("#").append(serNo).append(" ");
Date guaranteeDate = null;
//either date or timestamp
Object guarantee = rs.getObject(3);
if (guarantee != null)
{
if (guarantee instanceof Timestamp)
{
Timestamp ts = (Timestamp)guarantee;
guaranteeDate = new Date(ts.getTime());
}
else
{
guaranteeDate = (Date)guaranteeDate;
}
}
if (guaranteeDate != null)
sb.append(guaranteeDate).append(" ");
}
rs.close();
pstmt.close();
// Get Instance Info
sql = "SELECT ai.Value, a.Name "
+ "FROM M_AttributeInstance ai"
+ " INNER JOIN M_Attribute a ON (ai.M_Attribute_ID=a.M_Attribute_ID AND a.IsInstanceAttribute='Y') "
+ "WHERE ai.M_AttributeSetInstance_ID=?";
pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_M_AttributeSetInstance_ID);
rs = pstmt.executeQuery();
while (rs.next())
{
sb.append(rs.getString(1)) // value
.append(":").append(rs.getString(2)) // name
.append(" ");
}
rs.close();
pstmt.close();
if (sb.length() == 0)
return "";
sb.insert(0, " (");
sb.append(")");
return sb.toString();
} // getAttributeName
/**************************************************************************
* Get BOM Price Limit
* Previously: BOM_PriceLimit - Now: bomPriceLimit
* @param p_M_Product_ID
* @param p_M_PriceList_Version_ID
* @return Price Limit
* @throws SQLException
*/
public static BigDecimal bomPriceLimit (int p_M_Product_ID, int p_M_PriceList_Version_ID)
throws SQLException
{
return bomPrice(p_M_Product_ID, p_M_PriceList_Version_ID, "PriceLimit");
} // bomPriceLimit
/**
* Get BOM Price List
* Previously: BOM_PriceList - Now: bomPriceList
* @param p_M_Product_ID
* @param p_M_PriceList_Version_ID
* @return Price List
* @throws SQLException
*/
public static BigDecimal bomPriceList (int p_M_Product_ID, int p_M_PriceList_Version_ID)
throws SQLException
{
return bomPrice(p_M_Product_ID, p_M_PriceList_Version_ID, "PriceList");
} // bomPriceList
/**
* Get BOM Price Std
* Previously: BOM_PriceStd - Now: bomPriceStd
* @param p_M_Product_ID
* @param p_M_PriceList_Version_ID
* @return Price Std
* @throws SQLException
*/
public static BigDecimal bomPriceStd (int p_M_Product_ID, int p_M_PriceList_Version_ID)
throws SQLException
{
return bomPrice(p_M_Product_ID, p_M_PriceList_Version_ID, "PriceStd");
} // bomPriceStd
/**
* Get BOM Price
* @param p_M_Product_ID
* @param p_M_PriceList_Version_ID
* @param p_what variable name
* @return Price
* @throws SQLException
*/
static BigDecimal bomPrice (int p_M_Product_ID, int p_M_PriceList_Version_ID, String p_what)
throws SQLException
{
BigDecimal price = null;
// Try to get price from PriceList directly
String sql = "SELECT " + p_what
+ " FROM M_ProductPrice "
+ "WHERE M_PriceList_Version_ID=? AND M_Product_ID=?";
PreparedStatement pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_M_PriceList_Version_ID);
pstmt.setInt(2, p_M_Product_ID);
ResultSet rs = pstmt.executeQuery();
if (rs.next())
price = rs.getBigDecimal(1);
rs.close();
pstmt.close();
// Loop through BOM
if (price == null || price.signum() == 0)
{
price = Adempiere.ZERO;
sql = "SELECT b.M_ProductBOM_ID, b.BOMQty, p.IsBOM "
+ "FROM M_Product_BOM b, M_Product p "
+ "WHERE b.M_ProductBOM_ID=p.M_Product_ID"
+ " AND b.M_Product_ID=?";
pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_M_Product_ID);
rs = pstmt.executeQuery();
while (rs.next())
{
int M_ProductBOM_ID = rs.getInt(1);
BigDecimal qty = rs.getBigDecimal(2);
BigDecimal productPrice = bomPrice(M_ProductBOM_ID, p_M_PriceList_Version_ID, p_what);
productPrice = productPrice.multiply(qty);
price = price.add(productPrice);
}
rs.close();
pstmt.close();
}
return price;
} // bomPrice
/**************************************************************************
* Get BOM Quantity Available
* Previously: BOM_Qty_Available - Now: bomQtyAvailable
* @param p_M_Product_ID product
* @param p_M_Warehouse_ID warehouse
* @param p_M_Locator_ID locator
* @return Quantity Available
* @throws SQLException
*/
public static BigDecimal bomQtyAvailable (int p_M_Product_ID,
int p_M_Warehouse_ID, int p_M_Locator_ID)
throws SQLException
{
return bomQty(p_M_Product_ID, p_M_Warehouse_ID, p_M_Locator_ID, "QtyOnHand")
.subtract(bomQty(p_M_Product_ID, p_M_Warehouse_ID, p_M_Locator_ID, "QtyReserved"));
} // bomQtyAvailable
/**
* Get BOM Quantity OnHand
* Previously: BOM_Qty_OnHand - Now: bomQtyOnHand
* @param p_M_Product_ID product
* @param p_M_Warehouse_ID warehouse
* @param p_M_Locator_ID locator
* @return Quantity Available
* @throws SQLException
*/
public static BigDecimal bomQtyOnHand (int p_M_Product_ID,
int p_M_Warehouse_ID, int p_M_Locator_ID)
throws SQLException
{
return bomQty(p_M_Product_ID, p_M_Warehouse_ID, p_M_Locator_ID, "QtyOnHand");
} // bomQtyOnHand
/**
* Get BOM Quantity Ordered
* Previously: BOM_Qty_Ordered - Now: bomQtyOrdered
* @param p_M_Product_ID product
* @param p_M_Warehouse_ID warehouse
* @param p_M_Locator_ID locator
* @return Quantity Ordered
* @throws SQLException
*/
public static BigDecimal bomQtyOrdered (int p_M_Product_ID,
int p_M_Warehouse_ID, int p_M_Locator_ID)
throws SQLException
{
return bomQty(p_M_Product_ID, p_M_Warehouse_ID, p_M_Locator_ID, "QtyOrdered");
} // bomQtyOrdered
/**
* Get BOM Quantity Reserved
* Previously: BOM_Qty_Reserved - Now: bomQtyReserved
* @param p_M_Product_ID product
* @param p_M_Warehouse_ID warehouse
* @param p_M_Locator_ID locator
* @return Qyantity Reserved
* @throws SQLException
*/
public static BigDecimal bomQtyReserved (int p_M_Product_ID,
int p_M_Warehouse_ID, int p_M_Locator_ID)
throws SQLException
{
return bomQty(p_M_Product_ID, p_M_Warehouse_ID, p_M_Locator_ID, "QtyReserved");
} // bomQtyReserved
/**
* Get BOM Quantity
* @param p_M_Product_ID product
* @param p_M_Warehouse_ID warehouse
* @param p_M_Locator_ID locator
* @param p_what variable name
* @return Quantity
* @throws SQLException
*/
static BigDecimal bomQty (int p_M_Product_ID,
int p_M_Warehouse_ID, int p_M_Locator_ID, String p_what)
throws SQLException
{
// Check Parameters
int M_Warehouse_ID = p_M_Warehouse_ID;
if (M_Warehouse_ID == 0)
{
if (p_M_Locator_ID == 0)
return Adempiere.ZERO;
else
{
String sql = "SELECT M_Warehouse_ID "
+ "FROM M_Locator "
+ "WHERE M_Locator_ID=?";
M_Warehouse_ID = Adempiere.getSQLValue(sql, p_M_Locator_ID);
}
}
// begin globalqss 2005-10-11
// if (M_Warehouse_ID == 0)
if (M_Warehouse_ID == 0 || M_Warehouse_ID == -1)
// end globalqss 2005-10-11
return Adempiere.ZERO;
// Check, if product exists and if it is stocked
boolean isBOM = false;
String ProductType = null;
boolean isStocked = false;
String sql = "SELECT IsBOM, ProductType, IsStocked "
+ "FROM M_Product "
+ "WHERE M_Product_ID=?";
PreparedStatement pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_M_Product_ID);
ResultSet rs = pstmt.executeQuery();
if (rs.next())
{
isBOM = "Y".equals(rs.getString(1));
ProductType = rs.getString(2);
isStocked = "Y".equals(rs.getString(3));
}
rs.close();
pstmt.close();
// No Product
if (ProductType == null)
return Adempiere.ZERO;
// Unlimited capacity if no item
if (!isBOM && (!ProductType.equals("I") || !isStocked))
return UNLIMITED;
// Get Qty
if (isStocked)
return getStorageQty(p_M_Product_ID, M_Warehouse_ID, p_M_Locator_ID, p_what);
// Go through BOM
BigDecimal quantity = UNLIMITED;
BigDecimal productQuantity = null;
sql = "SELECT b.M_ProductBOM_ID, b.BOMQty, p.IsBOM, p.IsStocked, p.ProductType "
+ "FROM M_Product_BOM b, M_Product p "
+ "WHERE b.M_ProductBOM_ID=p.M_Product_ID"
+ " AND b.M_Product_ID=?";
pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_M_Product_ID);
rs = pstmt.executeQuery();
while (rs.next())
{
int M_ProductBOM_ID = rs.getInt(1);
BigDecimal bomQty = rs.getBigDecimal(2);
isBOM = "Y".equals(rs.getString(3));
isStocked = "Y".equals(rs.getString(4));
ProductType = rs.getString(5);
// Stocked Items "leaf node"
if (ProductType.equals("I") && isStocked)
{
// Get ProductQty
productQuantity = getStorageQty(M_ProductBOM_ID, M_Warehouse_ID, p_M_Locator_ID, p_what);
// Get Rounding Precision
int uomPrecision = getUOMPrecision(M_ProductBOM_ID);
// How much can we make with this product
//hengsin, [ 1649453 ] bomQtyAvailable sqlj function throw ArithmeticException
//productQuantity = productQuantity.setScale(uomPrecision)
// .divide(bomQty, uomPrecision, BigDecimal.ROUND_HALF_UP);
productQuantity = productQuantity.divide(bomQty, uomPrecision, BigDecimal.ROUND_HALF_UP);
// How much can we make overall
if (productQuantity.compareTo(quantity) < 0)
quantity = productQuantity;
}
else if (isBOM) // Another BOM
{
productQuantity = bomQty (M_ProductBOM_ID, M_Warehouse_ID, p_M_Locator_ID, p_what);
// How much can we make overall
if (productQuantity.compareTo(quantity) < 0)
quantity = productQuantity;
}
}
rs.close();
pstmt.close();
if (quantity.signum() != 0)
{
int uomPrecision = getUOMPrecision(p_M_Product_ID);
return quantity.setScale(uomPrecision, BigDecimal.ROUND_HALF_UP);
}
return Adempiere.ZERO;
} // bomQtyOnHand
/** Unlimited Quantity */
private static final BigDecimal UNLIMITED = new BigDecimal((double)99999.0);
/**
* Get Storage Qty
* @param p_M_Product_ID product
* @param M_Warehouse_ID warehouse
* @param p_M_Locator_ID locator
* @param p_what variable name
* @return quantity or zero
* @throws SQLException
*/
static BigDecimal getStorageQty (int p_M_Product_ID,
int M_Warehouse_ID, int p_M_Locator_ID, String p_what)
throws SQLException
{
BigDecimal quantity = null;
String sql = "SELECT SUM(" + p_what + ") "
+ "FROM M_Storage s "
+ "WHERE M_Product_ID=?";
if (p_M_Locator_ID != 0)
sql += " AND s.M_Locator_ID=?";
else
sql += " AND EXISTS (SELECT * FROM M_Locator l WHERE s.M_Locator_ID=l.M_Locator_ID"
+ " AND l.M_Warehouse_ID=?)";
PreparedStatement pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_M_Product_ID);
if (p_M_Locator_ID != 0)
pstmt.setInt(2, p_M_Locator_ID);
else
pstmt.setInt(2, M_Warehouse_ID);
ResultSet rs = pstmt.executeQuery();
if (rs.next())
quantity = rs.getBigDecimal(1);
rs.close();
pstmt.close();
// Not found
if (quantity == null)
return Adempiere.ZERO;
return quantity;
} // getStorageQty
/**
* Get UOM Precision for Product
* @param p_M_Product_ID product
* @return precision or 0
* @throws SQLException
*/
static int getUOMPrecision (int p_M_Product_ID) throws SQLException
{
int precision = 0;
String sql = "SELECT u.StdPrecision "
+ "FROM C_UOM u"
+ " INNER JOIN M_Product p ON (u.C_UOM_ID=p.C_UOM_ID) "
+ "WHERE p.M_Product_ID=?";
PreparedStatement pstmt = Adempiere.prepareStatement(sql);
pstmt.setInt(1, p_M_Product_ID);
ResultSet rs = pstmt.executeQuery();
if (rs.next())
precision = rs.getInt(1);
rs.close();
pstmt.close();
return precision;
} // getStdPrecision
/**
* Test
* @param args
*
public static void main (String[] args)
{
try
{
DriverManager.registerDriver(new oracle.jdbc.driver.OracleDriver());
Adempiere.s_type = Adempiere.TYPE_ORACLE;
Adempiere.s_url = "jdbc:oracle:thin:@//dev1:1521/dev1.adempiere.org";
Adempiere.s_uid = "adempiere";
Adempiere.s_pwd = "adempiere";
// System.out.println(Product.bomQtyOnHand(p_M_Product_ID, 0, p_M_Locator_ID));
}
catch (SQLException e)
{
e.printStackTrace();
}
} // main /* */
} // Product