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

CreateCostElement: 

* fix M_Cost creation
* improved performances
This commit is contained in:
teo_sarca 2008-09-17 10:38:59 +00:00
parent ec95527738
commit 8937778bab
1 changed files with 57 additions and 41 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

80
base/src/org/eevolution/process/CreateCostElement.java
View File

@ -12,17 +12,19 @@
* For the text or an alternative of this public license, you may reach us * * For the text or an alternative of this public license, you may reach us *
* Copyright (C) 2003-2007 e-Evolution,SC. All Rights Reserved. * * Copyright (C) 2003-2007 e-Evolution,SC. All Rights Reserved. *
* Contributor(s): Victor Perez www.e-evolution.com * * Contributor(s): Victor Perez www.e-evolution.com *
* Teo Sarca, www.arhipac.ro *
*****************************************************************************/ *****************************************************************************/
package org.eevolution.process; package org.eevolution.process;
import java.sql.PreparedStatement; import java.sql.PreparedStatement;
import java.sql.ResultSet; import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList; import java.util.ArrayList;
import java.util.logging.Level; import java.util.logging.Level;
import org.adempiere.exceptions.AdempiereException;
import org.adempiere.exceptions.DBException; import org.adempiere.exceptions.DBException;
import org.compiere.model.MAcctSchema;
import org.compiere.model.MCost; import org.compiere.model.MCost;
import org.compiere.model.MCostElement; import org.compiere.model.MCostElement;
import org.compiere.model.MProduct; import org.compiere.model.MProduct;
@ -37,6 +39,8 @@ import org.compiere.util.DB;
* *
* @author victor.perez@e-evolution.com, e-Evolution, S.C. * @author victor.perez@e-evolution.com, e-Evolution, S.C.
* @version $Id: CreateCostElement.java,v 1.1 2004/06/22 05:24:03 vpj-cd Exp $ * @version $Id: CreateCostElement.java,v 1.1 2004/06/22 05:24:03 vpj-cd Exp $
*
* @author Teo Sarca, www.arhipac.ro
*/ */
public class CreateCostElement extends SvrProcess public class CreateCostElement extends SvrProcess
{ {
@ -91,30 +95,54 @@ public class CreateCostElement extends SvrProcess
protected String doIt() throws Exception protected String doIt() throws Exception
{ {
MAcctSchema as = MAcctSchema.get(getCtx(), p_C_AcctSchema_ID);
int count_costs = 0; int count_costs = 0;
ArrayList<Object> params = new ArrayList<Object>(); ArrayList<Object> params = new ArrayList<Object>();
String sql = "SELECT M_Product_ID FROM M_Product WHERE AD_Client_ID=?"; String sql = "SELECT org.AD_Org_ID, p.M_Product_ID, ce.M_CostElement_ID"
+" FROM AD_Org org, M_Product p, M_CostElement ce"
+" WHERE ";
sql += "org.AD_Client_ID=? AND p.AD_Client_ID=org.AD_Client_ID AND ce.AD_Client_ID=p.AD_Client_ID";
params.add(getAD_Client_ID()); params.add(getAD_Client_ID());
if (p_M_Product_Category_ID != 0)
if (p_AD_Org_ID > 0)
{ {
sql = sql + " AND M_Product_Category_ID=?"; sql += " AND org.AD_Org_ID=?";
params.add(p_AD_Org_ID);
}
if (p_M_Product_Category_ID > 0)
{
sql += " AND p."+MProduct.COLUMNNAME_M_Product_Category_ID+"=?";
params.add(p_M_Product_Category_ID); params.add(p_M_Product_Category_ID);
} }
if (p_M_Product_ID != 0) if (p_M_Product_ID > 0)
{ {
sql = sql + " AND M_Product_ID=?"; sql += " AND p."+MProduct.COLUMNNAME_M_Product_ID+"=?";
params.add(p_M_Product_ID); params.add(p_M_Product_ID);
} }
if (p_M_CostElement_ID > 0)
MCostElement[] elements = MCostElement.getElements(getCtx(), get_TrxName());
if (elements.length == 0)
{ {
throw new AdempiereException("@NotFound@ @M_CostElement_ID@"); sql += " AND ce."+MCostElement.COLUMNNAME_M_CostElement_ID+"=?";
params.add(p_M_CostElement_ID);
} }
// M_Cost not already created:
sql += " AND NOT EXISTS (SELECT 1 FROM M_Cost c WHERE"
+" c.AD_Client_ID=ce.AD_Client_ID"
+" AND c.AD_Org_ID=org.AD_Org_ID"
+" AND c.M_Product_ID=p.M_Product_ID"
+" AND c.C_AcctSchema_ID=?"
+" AND c.M_CostType_ID=?"
+" AND c.M_CostElement_ID=ce.M_CostElement_ID)";
params.add(p_C_AcctSchema_ID);
params.add(p_M_CostType_ID);
// ORDER BY
sql += " ORDER BY p."+MProduct.COLUMNNAME_M_Product_ID;
PreparedStatement pstmt = null; PreparedStatement pstmt = null;
ResultSet rs = null; ResultSet rs = null;
try try
@ -124,32 +152,21 @@ public class CreateCostElement extends SvrProcess
rs = pstmt.executeQuery (); rs = pstmt.executeQuery ();
while (rs.next()) while (rs.next())
{ {
int m_M_Product_ID = rs.getInt(MProduct.COLUMNNAME_M_Product_ID); int AD_Org_ID = rs.getInt("AD_Org_ID");
MCost[] costs = MCost.getCosts(getCtx(), getAD_Client_ID(), p_AD_Org_ID, int M_Product_ID = rs.getInt(MProduct.COLUMNNAME_M_Product_ID);
m_M_Product_ID, p_M_CostType_ID, p_C_AcctSchema_ID, int M_CostElement_ID = rs.getInt(MCostElement.COLUMNNAME_M_CostElement_ID);
get_TrxName()); int M_ASI_ID = 0;
if (costs.length == 0) MProduct product = MProduct.get(getCtx(), M_Product_ID);
{ //
for(MCostElement element : elements) MCost cost = new MCost(product, M_ASI_ID, as, AD_Org_ID, M_CostElement_ID);
{
if(p_M_CostElement_ID > 0 && element.get_ID() != p_M_CostElement_ID)
continue;
MCost cost = new MCost(getCtx(), 0, get_TrxName());
cost.setM_Product_ID(m_M_Product_ID);
cost.setAD_Org_ID(p_AD_Org_ID);
cost.setC_AcctSchema_ID(p_C_AcctSchema_ID);
cost.setM_CostType_ID(p_M_CostType_ID); cost.setM_CostType_ID(p_M_CostType_ID);
cost.setM_CostElement_ID(element.get_ID()); cost.saveEx(get_TrxName());
cost.saveEx();
count_costs++; count_costs++;
} }
} }
} catch (SQLException e)
}
catch (Exception e)
{ {
throw new DBException(e); throw new DBException(e, sql);
} }
finally finally
{ {
@ -159,5 +176,4 @@ public class CreateCostElement extends SvrProcess
return "@Created@ #"+count_costs; return "@Created@ #"+count_costs;
} }
} // Create Cost Element } // Create Cost Element