Bug Fix [ 1746900 ] Add or Copy Accounts failing
This commit is contained in:
Carlos Ruiz
parent
143eba41bb
commit
f48f1e20ef
|
|
@ -1,455 +0,0 @@
|
||||||
/******************************************************************************
|
|
||||||
* 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 *
|
|
||||||
* Portions created by Carlos Ruiz are Copyright (C) 2005 QSS Ltda.
|
|
||||||
* Contributor(s): Carlos Ruiz (globalqss)
|
|
||||||
*****************************************************************************/
|
|
||||||
package org.compiere.process;
|
|
||||||
|
|
||||||
import java.sql.*;
|
|
||||||
import java.util.logging.*;
|
|
||||||
|
|
||||||
import org.compiere.util.*;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Title: Copy Acct Info
|
|
||||||
* Description:
|
|
||||||
* Copy Accounting Schema information to elements
|
|
||||||
* (Existing entities are overwritten) cascade all!
|
|
||||||
*
|
|
||||||
* @author Carlos Ruiz (globalqss)
|
|
||||||
* @version $Id: C_AcctSchema_Default_Copy.java,v 1.0 2005/10/31 14:09:00 globalqss Exp $
|
|
||||||
*/
|
|
||||||
public class C_AcctSchema_Default_Copy extends SvrProcess
|
|
||||||
{
|
|
||||||
|
|
||||||
/*
|
|
||||||
* NOTE: The original oracle procedure C_AcctSchema_Default_Copy had a
|
|
||||||
* Client_ID parameter for Direct Call not implemented in this class
|
|
||||||
*/
|
|
||||||
|
|
||||||
/** The Business Partner Group */
|
|
||||||
private int ad_Client_ID = -1;
|
|
||||||
/** The Record */
|
|
||||||
private int p_Record_ID = 0;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Prepare - e.g., get Parameters.
|
|
||||||
*/
|
|
||||||
protected void prepare()
|
|
||||||
{
|
|
||||||
ProcessInfoParameter[] para = getParameter();
|
|
||||||
for (int i = 0; i < para.length; i++)
|
|
||||||
{
|
|
||||||
String name = para[i].getParameterName();
|
|
||||||
if (para[i].getParameter() == null)
|
|
||||||
;
|
|
||||||
else if (name.equals("AD_Client_ID"))
|
|
||||||
ad_Client_ID = para[i].getParameterAsInt();
|
|
||||||
else
|
|
||||||
log.log(Level.SEVERE, "Unknown Parameter: " + name);
|
|
||||||
}
|
|
||||||
p_Record_ID = getRecord_ID();
|
|
||||||
} // prepare
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Process
|
|
||||||
* @return message
|
|
||||||
* @throws Exception
|
|
||||||
*/
|
|
||||||
protected String doIt() throws Exception
|
|
||||||
{
|
|
||||||
String sql;
|
|
||||||
String sqlupd;
|
|
||||||
String sqlins;
|
|
||||||
int cntu = 0;
|
|
||||||
int cnti = 0;
|
|
||||||
int totu = 0;
|
|
||||||
int toti = 0;
|
|
||||||
|
|
||||||
log.info("For all Accounting Schema");
|
|
||||||
/**
|
|
||||||
* For all Accounting Schema
|
|
||||||
*/
|
|
||||||
sql = "SELECT * FROM C_AcctSchema_Default WHERE AD_Client_ID = " + ad_Client_ID;
|
|
||||||
PreparedStatement pstmt = null;
|
|
||||||
try
|
|
||||||
{
|
|
||||||
pstmt = DB.prepareStatement(sql, get_TrxName());
|
|
||||||
ResultSet rs = pstmt.executeQuery();
|
|
||||||
while (rs.next())
|
|
||||||
{
|
|
||||||
// Update existing Product Category
|
|
||||||
sqlupd = "UPDATE M_Product_Category_Acct "
|
|
||||||
+ "SET P_Revenue_Acct=" + rs.getInt("P_Revenue_Acct") + ", "
|
|
||||||
+ "P_Expense_Acct=" + rs.getInt("P_Expense_Acct") + ", "
|
|
||||||
+ "P_Asset_Acct=" + rs.getInt("P_Asset_Acct") + ", "
|
|
||||||
+ "P_CoGs_Acct=" + rs.getInt("P_CoGs_Acct") + ", "
|
|
||||||
+ "P_PurchasePriceVariance_Acct=" + rs.getInt("P_PurchasePriceVariance_Acct") + ", "
|
|
||||||
+ "P_InvoicePriceVariance_Acct=" + rs.getInt("P_InvoicePriceVariance_Acct") + ", "
|
|
||||||
+ "P_TradeDiscountRec_Acct=" + rs.getInt("P_TradeDiscountRec_Acct") + ", "
|
|
||||||
+ "P_TradeDiscountGrant_Acct=" + rs.getInt("P_TradeDiscountGrant_Acct") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE M_Product_Category_Acct.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM M_Product_Category p "
|
|
||||||
+ "WHERE p.M_Product_Category_ID=M_Product_Category_Acct.M_Product_Category_ID)";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new Product Category
|
|
||||||
sqlins = "INSERT INTO M_Product_Category_Acct "
|
|
||||||
+ "(M_Product_Category_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "P_Revenue_Acct, P_Expense_Acct, P_Asset_Acct, P_CoGs_Acct, "
|
|
||||||
+ "P_PurchasePriceVariance_Acct, P_InvoicePriceVariance_Acct, "
|
|
||||||
+ "P_TradeDiscountRec_Acct, P_TradeDiscountGrant_Acct) "
|
|
||||||
+ "SELECT p.M_Product_Category_ID, " + rs.getInt("C_AcctSchema_ID") + ", "
|
|
||||||
+ "p.AD_Client_ID, p.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ rs.getInt("P_Revenue_Acct") + ", " + rs.getInt("P_Expense_Acct") + ", "
|
|
||||||
+ rs.getInt("P_Asset_Acct") + ", " + rs.getInt("P_CoGs_Acct") + ", "
|
|
||||||
+ rs.getInt("P_PurchasePriceVariance_Acct") + ", " + rs.getInt("P_InvoicePriceVariance_Acct") + ", "
|
|
||||||
+ rs.getInt("P_TradeDiscountRec_Acct") + ", " + rs.getInt("P_TradeDiscountGrant_Acct") + " "
|
|
||||||
+ "FROM M_Product_Category p "
|
|
||||||
+ "WHERE AD_Client_ID=" + rs.getInt("AD_Client_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM M_Product_Category_Acct pa "
|
|
||||||
+ "WHERE pa.M_Product_Category_ID=p.M_Product_Category_ID "
|
|
||||||
+ "AND pa.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Product Category = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
// Business Partner Group
|
|
||||||
sqlupd = "UPDATE C_BP_Group_Acct "
|
|
||||||
+ "SET C_Receivable_Acct=" + rs.getInt("C_Receivable_Acct") + ", "
|
|
||||||
+ "C_PrePayment_Acct=" + rs.getInt("C_PrePayment_Acct") + ", "
|
|
||||||
+ "V_Liability_Acct=" + rs.getInt("V_Liability_Acct") + ", "
|
|
||||||
+ "V_Liability_Services_Acct=" + rs.getInt("V_Liability_Services_Acct") + ", "
|
|
||||||
+ "V_PrePayment_Acct=" + rs.getInt("V_PrePayment_Acct") + ", "
|
|
||||||
+ "PayDiscount_Exp_Acct=" + rs.getInt("PayDiscount_Exp_Acct") + ", "
|
|
||||||
+ "PayDiscount_Rev_Acct=" + rs.getInt("PayDiscount_Rev_Acct") + ", "
|
|
||||||
+ "WriteOff_Acct=" + rs.getInt("WriteOff_Acct") + ", "
|
|
||||||
+ "NotInvoicedReceipts_Acct=" + rs.getInt("NotInvoicedReceipts_Acct") + ", "
|
|
||||||
+ "UnEarnedRevenue_Acct=" + rs.getInt("UnEarnedRevenue_Acct") + ", "
|
|
||||||
+ "NotInvoicedRevenue_Acct=" + rs.getInt("NotInvoicedRevenue_Acct") + ", "
|
|
||||||
+ "NotInvoicedReceivables_Acct=" + rs.getInt("NotInvoicedReceivables_Acct") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE C_BP_Group_Acct.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM C_BP_Group_Acct x "
|
|
||||||
+ "WHERE x.C_BP_Group_ID=C_BP_Group_Acct.C_BP_Group_ID)";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new
|
|
||||||
sqlins = "INSERT INTO C_BP_Group_Acct "
|
|
||||||
+ "(C_BP_Group_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "C_Receivable_Acct, C_PrePayment_Acct, "
|
|
||||||
+ "V_Liability_Acct, V_Liability_Services_Acct, V_PrePayment_Acct, "
|
|
||||||
+ "PayDiscount_Exp_Acct, PayDiscount_Rev_Acct, WriteOff_Acct, "
|
|
||||||
+ "NotInvoicedReceipts_Acct, UnEarnedRevenue_Acct, "
|
|
||||||
+ "NotInvoicedRevenue_Acct, NotInvoicedReceivables_Acct) "
|
|
||||||
+ "SELECT x.C_BP_Group_ID, " + rs.getInt("C_AcctSchema_ID") + ", "
|
|
||||||
+ "x.AD_Client_ID, x.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ rs.getInt("C_Receivable_Acct") + ", " + rs.getInt("C_PrePayment_Acct") + ", "
|
|
||||||
+ rs.getInt("V_Liability_Acct") + ", " + rs.getInt("V_Liability_Services_Acct") + ", "
|
|
||||||
+ rs.getInt("V_PrePayment_Acct") + ", "
|
|
||||||
+ rs.getInt("PayDiscount_Exp_Acct") + ", " + rs.getInt("PayDiscount_Rev_Acct") + ", "
|
|
||||||
+ rs.getInt("WriteOff_Acct") + ", "
|
|
||||||
+ rs.getInt("NotInvoicedReceipts_Acct") + ", " + rs.getInt("UnEarnedRevenue_Acct") + ", "
|
|
||||||
+ rs.getInt("NotInvoicedRevenue_Acct") + ", " + rs.getInt("NotInvoicedReceivables_Acct") + " "
|
|
||||||
+ "FROM C_BP_Group x "
|
|
||||||
+ "WHERE AD_Client_ID=" + rs.getInt("AD_Client_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM C_BP_Group_Acct a "
|
|
||||||
+ "WHERE a.C_BP_Group_ID=x.C_BP_Group_ID "
|
|
||||||
+ "AND a.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Business Group = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
// Business Partner Employee
|
|
||||||
sqlupd = "UPDATE C_BP_Employee_Acct "
|
|
||||||
+ "SET E_Expense_Acct=" + rs.getInt("E_Expense_Acct") + ", "
|
|
||||||
+ "E_PrePayment_Acct=" + rs.getInt("E_PrePayment_Acct") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE C_BP_Employee_Acct.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM C_BP_Employee_Acct x "
|
|
||||||
+ "WHERE x.C_BPartner_ID=C_BP_Employee_Acct.C_BPartner_ID)";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new
|
|
||||||
sqlins = "INSERT INTO C_BP_Employee_Acct "
|
|
||||||
+ "(C_BPartner_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "E_Expense_Acct, E_PrePayment_Acct) "
|
|
||||||
+ "SELECT x.C_BPartner_ID, " + rs.getInt("C_AcctSchema_ID") + ", "
|
|
||||||
+ "x.AD_Client_ID, x.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ "" + rs.getInt("E_Expense_Acct") + ", " + rs.getInt("E_PrePayment_Acct") + " "
|
|
||||||
+ "FROM C_BPartner x "
|
|
||||||
+ "WHERE AD_Client_ID=" + rs.getInt("AD_Client_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM C_BP_Employee_Acct a "
|
|
||||||
+ "WHERE a.C_BPartner_ID=x.C_BPartner_ID "
|
|
||||||
+ "AND a.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Employees = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
// Warehouse
|
|
||||||
sqlupd = "UPDATE M_Warehouse_Acct "
|
|
||||||
+ "SET W_Inventory_Acct=" + rs.getInt("W_Inventory_Acct") + ", "
|
|
||||||
+ "W_Differences_Acct=" + rs.getInt("W_Differences_Acct") + ", "
|
|
||||||
+ "W_Revaluation_Acct=" + rs.getInt("W_Revaluation_Acct") + ", "
|
|
||||||
+ "W_InvActualAdjust_Acct=" + rs.getInt("W_InvActualAdjust_Acct") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE M_Warehouse_Acct.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM M_Warehouse_Acct x "
|
|
||||||
+ "WHERE x.M_Warehouse_ID=M_Warehouse_Acct.M_Warehouse_ID)";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new
|
|
||||||
sqlins = "INSERT INTO M_Warehouse_Acct "
|
|
||||||
+ "(M_Warehouse_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "W_Inventory_Acct, W_Differences_Acct, W_Revaluation_Acct, W_InvActualAdjust_Acct) "
|
|
||||||
+ "SELECT x.M_Warehouse_ID, " + rs.getInt("C_AcctSchema_ID") + ", "
|
|
||||||
+ "x.AD_Client_ID, x.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ "" + rs.getInt("W_Inventory_Acct") + ", " + rs.getInt("W_Differences_Acct") + ", " + rs.getInt("W_Revaluation_Acct") + ", " + rs.getInt("W_InvActualAdjust_Acct") + " "
|
|
||||||
+ "FROM M_Warehouse x "
|
|
||||||
+ "WHERE AD_Client_ID=" + rs.getInt("AD_Client_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM M_Warehouse_Acct a "
|
|
||||||
+ "WHERE a.M_Warehouse_ID=x.M_Warehouse_ID "
|
|
||||||
+ "AND a.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Warehouse = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
// Project
|
|
||||||
sqlupd = "UPDATE C_Project_Acct "
|
|
||||||
+ "SET PJ_Asset_Acct=" + rs.getInt("PJ_Asset_Acct") + ", "
|
|
||||||
+ "PJ_WIP_Acct=" + rs.getInt("PJ_Asset_Acct") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE C_Project_Acct.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM C_Project_Acct x "
|
|
||||||
+ "WHERE x.C_Project_ID=C_Project_Acct.C_Project_ID)";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new
|
|
||||||
sqlins = "INSERT INTO C_Project_Acct "
|
|
||||||
+ "(C_Project_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "PJ_Asset_Acct, PJ_WIP_Acct) "
|
|
||||||
+ "SELECT x.C_Project_ID, " + rs.getInt("C_AcctSchema_ID") + ", "
|
|
||||||
+ "x.AD_Client_ID, x.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ "" + rs.getInt("PJ_Asset_Acct") + ", " + rs.getInt("PJ_WIP_Acct") + " "
|
|
||||||
+ "FROM C_Project x "
|
|
||||||
+ "WHERE AD_Client_ID=" + rs.getInt("AD_Client_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM C_Project_Acct a "
|
|
||||||
+ "WHERE a.C_Project_ID=x.C_Project_ID "
|
|
||||||
+ "AND a.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Project = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
// Tax
|
|
||||||
sqlupd = "UPDATE C_Tax_Acct "
|
|
||||||
+ "SET T_Due_Acct=" + rs.getInt("T_Due_Acct") + ", "
|
|
||||||
+ "T_Liability_Acct=" + rs.getInt("T_Liability_Acct") + ", "
|
|
||||||
+ "T_Credit_Acct=" + rs.getInt("T_Credit_Acct") + ", "
|
|
||||||
+ "T_Receivables_Acct=" + rs.getInt("T_Receivables_Acct") + ", "
|
|
||||||
+ "T_Expense_Acct=" + rs.getInt("T_Expense_Acct") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE C_Tax_Acct.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM C_Tax_Acct x "
|
|
||||||
+ "WHERE x.C_Tax_ID=C_Tax_Acct.C_Tax_ID)";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new
|
|
||||||
sqlins = "INSERT INTO C_Tax_Acct "
|
|
||||||
+ "(C_Tax_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "T_Due_Acct, T_Liability_Acct, T_Credit_Acct, T_Receivables_Acct, T_Expense_Acct) "
|
|
||||||
+ "SELECT x.C_Tax_ID, " + rs.getInt("C_AcctSchema_ID") + ", "
|
|
||||||
+ "x.AD_Client_ID, x.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ "" + rs.getInt("T_Due_Acct") + ", " + rs.getInt("T_Liability_Acct") + ", " + rs.getInt("T_Credit_Acct") + ", " + rs.getInt("T_Receivables_Acct") + ", " + rs.getInt("T_Expense_Acct") + " "
|
|
||||||
+ "FROM C_Tax x "
|
|
||||||
+ "WHERE AD_Client_ID=" + rs.getInt("AD_Client_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM C_Tax_Acct a "
|
|
||||||
+ "WHERE a.C_Tax_ID=x.C_Tax_ID "
|
|
||||||
+ "AND a.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Tax = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
// BankAccount
|
|
||||||
sqlupd = "UPDATE C_BankAccount_Acct "
|
|
||||||
+ "SET B_InTransit_Acct=" + rs.getInt("B_InTransit_Acct") + ", "
|
|
||||||
+ "B_Asset_Acct=" + rs.getInt("B_Asset_Acct") + ", "
|
|
||||||
+ "B_Expense_Acct=" + rs.getInt("B_Expense_Acct") + ", "
|
|
||||||
+ "B_InterestRev_Acct=" + rs.getInt("B_InterestRev_Acct") + ", "
|
|
||||||
+ "B_InterestExp_Acct=" + rs.getInt("B_InterestExp_Acct") + ", "
|
|
||||||
+ "B_UnIdentified_Acct=" + rs.getInt("B_UnIdentified_Acct") + ", "
|
|
||||||
+ "B_UnAllocatedCash_Acct=" + rs.getInt("B_UnAllocatedCash_Acct") + ", "
|
|
||||||
+ "B_PaymentSelect_Acct=" + rs.getInt("B_PaymentSelect_Acct") + ", "
|
|
||||||
+ "B_SettlementGain_Acct=" + rs.getInt("B_SettlementGain_Acct") + ", "
|
|
||||||
+ "B_SettlementLoss_Acct=" + rs.getInt("B_SettlementLoss_Acct") + ", "
|
|
||||||
+ "B_RevaluationGain_Acct=" + rs.getInt("B_RevaluationGain_Acct") + ", "
|
|
||||||
+ "B_RevaluationLoss_Acct=" + rs.getInt("B_RevaluationLoss_Acct") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE C_BankAccount_Acct.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM C_BankAccount_Acct x "
|
|
||||||
+ "WHERE x.C_BankAccount_ID=C_BankAccount_Acct.C_BankAccount_ID)";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new
|
|
||||||
sqlins = "INSERT INTO C_BankAccount_Acct "
|
|
||||||
+ "(C_BankAccount_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "B_InTransit_Acct, B_Asset_Acct, B_Expense_Acct, B_InterestRev_Acct, B_InterestExp_Acct, "
|
|
||||||
+ "B_UnIdentified_Acct, B_UnAllocatedCash_Acct, B_PaymentSelect_Acct, "
|
|
||||||
+ "B_SettlementGain_Acct, B_SettlementLoss_Acct, "
|
|
||||||
+ "B_RevaluationGain_Acct, B_RevaluationLoss_Acct) "
|
|
||||||
+ "SELECT x.C_BankAccount_ID, " + rs.getInt("C_AcctSchema_ID") + ", "
|
|
||||||
+ "x.AD_Client_ID, x.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ "" + rs.getInt("B_InTransit_Acct") + ", " + rs.getInt("B_Asset_Acct") + ", " + rs.getInt("B_Expense_Acct") + ", " + rs.getInt("B_InterestRev_Acct") + ", " + rs.getInt("B_InterestExp_Acct") + ", "
|
|
||||||
+ "" + rs.getInt("B_UnIdentified_Acct") + ", " + rs.getInt("B_UnAllocatedCash_Acct") + ", " + rs.getInt("B_PaymentSelect_Acct") + ", "
|
|
||||||
+ "" + rs.getInt("B_SettlementGain_Acct") + ", " + rs.getInt("B_SettlementLoss_Acct") + ", "
|
|
||||||
+ "" + rs.getInt("B_RevaluationGain_Acct") + ", " + rs.getInt("B_RevaluationLoss_Acct") + " "
|
|
||||||
+ "FROM C_BankAccount x "
|
|
||||||
+ "WHERE AD_Client_ID=" + rs.getInt("AD_Client_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM C_BankAccount_Acct a "
|
|
||||||
+ "WHERE a.C_BankAccount_ID=x.C_BankAccount_ID "
|
|
||||||
+ "AND a.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Bank Account = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
// Withholding
|
|
||||||
sqlupd = "UPDATE C_Withholding_Acct "
|
|
||||||
+ "SET Withholding_Acct=" + rs.getInt("Withholding_Acct") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE C_Withholding_Acct.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM C_Withholding_Acct x "
|
|
||||||
+ "WHERE x.C_Withholding_ID=C_Withholding_Acct.C_Withholding_ID)";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new
|
|
||||||
sqlins = "INSERT INTO C_Withholding_Acct "
|
|
||||||
+ "(C_Withholding_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "Withholding_Acct) "
|
|
||||||
+ "SELECT x.C_Withholding_ID, " + rs.getInt("C_AcctSchema_ID") + ", "
|
|
||||||
+ "x.AD_Client_ID, x.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ "" + rs.getInt("Withholding_Acct") + " "
|
|
||||||
+ "FROM C_Withholding x "
|
|
||||||
+ "WHERE AD_Client_ID=" + rs.getInt("AD_Client_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM C_Withholding_Acct a "
|
|
||||||
+ "WHERE a.C_Withholding_ID=x.C_Withholding_ID "
|
|
||||||
+ "AND a.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Withholding = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
// Charge
|
|
||||||
sqlupd = "UPDATE C_Charge_Acct "
|
|
||||||
+ "SET Ch_Expense_Acct=" + rs.getInt("Ch_Expense_Acct") + ", "
|
|
||||||
+ "Ch_Revenue_Acct=" + rs.getInt("Ch_Revenue_Acct") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE C_Charge_Acct.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM C_Charge_Acct x "
|
|
||||||
+ "WHERE x.C_Charge_ID=C_Charge_Acct.C_Charge_ID)";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new
|
|
||||||
sqlins = "INSERT INTO C_Charge_Acct "
|
|
||||||
+ "(C_Charge_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "Ch_Expense_Acct, Ch_Revenue_Acct) "
|
|
||||||
+ "SELECT x.C_Charge_ID, " + rs.getInt("C_AcctSchema_ID") + ", "
|
|
||||||
+ "x.AD_Client_ID, x.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ "" + rs.getInt("Ch_Expense_Acct") + ", " + rs.getInt("Ch_Revenue_Acct") + " "
|
|
||||||
+ "FROM C_Charge x "
|
|
||||||
+ "WHERE AD_Client_ID=" + rs.getInt("AD_Client_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM C_Charge_Acct a "
|
|
||||||
+ "WHERE a.C_Charge_ID=x.C_Charge_ID "
|
|
||||||
+ "AND a.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Charge = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
// Cashbook
|
|
||||||
sqlupd = "UPDATE C_Cashbook_Acct "
|
|
||||||
+ "SET CB_Asset_Acct=" + rs.getInt("CB_Asset_Acct") + ", "
|
|
||||||
+ "CB_Differences_Acct=" + rs.getInt("CB_Differences_Acct") + ", "
|
|
||||||
+ "CB_CashTransfer_Acct=" + rs.getInt("CB_CashTransfer_Acct") + ", "
|
|
||||||
+ "CB_Expense_Acct=" + rs.getInt("CB_Expense_Acct") + ", "
|
|
||||||
+ "CB_Receipt_Acct=" + rs.getInt("CB_Receipt_Acct") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE C_Cashbook_Acct.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM C_Cashbook_Acct x "
|
|
||||||
+ "WHERE x.C_Cashbook_ID=C_Cashbook_Acct.C_Cashbook_ID)";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new
|
|
||||||
sqlins = "INSERT INTO C_Cashbook_Acct "
|
|
||||||
+ "(C_Cashbook_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "CB_Asset_Acct, CB_Differences_Acct, CB_CashTransfer_Acct, "
|
|
||||||
+ "CB_Expense_Acct, CB_Receipt_Acct) "
|
|
||||||
+ "SELECT x.C_Cashbook_ID, " + rs.getInt("C_AcctSchema_ID") + ", "
|
|
||||||
+ "x.AD_Client_ID, x.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ "" + rs.getInt("CB_Asset_Acct") + ", " + rs.getInt("CB_Differences_Acct") + ", " + rs.getInt("CB_CashTransfer_Acct") + ", "
|
|
||||||
+ "" + rs.getInt("CB_Expense_Acct") + ", " + rs.getInt("CB_Receipt_Acct") + " "
|
|
||||||
+ "FROM C_Cashbook x "
|
|
||||||
+ "WHERE AD_Client_ID=" + rs.getInt("AD_Client_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM C_Cashbook_Acct a "
|
|
||||||
+ "WHERE C_Cashbook_Acct.C_Cashbook_ID=x.C_Cashbook_ID "
|
|
||||||
+ "AND C_Cashbook_Acct.C_AcctSchema_ID=" + rs.getInt("C_AcctSchema_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Cashbook = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
}
|
|
||||||
rs.close();
|
|
||||||
pstmt.close();
|
|
||||||
pstmt = null;
|
|
||||||
log.fine("Committing ...");
|
|
||||||
DB.commit(true, get_TrxName());
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
log.log(Level.SEVERE, "adding missing elements", e);
|
|
||||||
}
|
|
||||||
try
|
|
||||||
{
|
|
||||||
if (pstmt != null)
|
|
||||||
pstmt.close();
|
|
||||||
pstmt = null;
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
pstmt = null;
|
|
||||||
}
|
|
||||||
|
|
||||||
return "@Created@=" + cnti + ", @Updated@=" + cntu;
|
|
||||||
} // doIt
|
|
||||||
|
|
||||||
} // C_AcctSchema_Default_Copy
|
|
||||||
|
|
@ -1,176 +0,0 @@
|
||||||
/******************************************************************************
|
|
||||||
* 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 *
|
|
||||||
* Portions created by Carlos Ruiz are Copyright (C) 2005 QSS Ltda.
|
|
||||||
* Contributor(s): Carlos Ruiz (globalqss)
|
|
||||||
*****************************************************************************/
|
|
||||||
package org.compiere.process;
|
|
||||||
|
|
||||||
import java.sql.*;
|
|
||||||
import java.util.logging.*;
|
|
||||||
|
|
||||||
import org.compiere.util.*;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Title: Copy Acct Info
|
|
||||||
* Description:
|
|
||||||
* Copy Accounting Info to all Business Partner Account Info elements
|
|
||||||
* (existing entries are overwritten)
|
|
||||||
*
|
|
||||||
* @author Carlos Ruiz (globalqss)
|
|
||||||
* @version $Id: C_BP_Group_Acct_Copy.java,v 1.0 2005/09/19 23:13:00 globalqss Exp $
|
|
||||||
*/
|
|
||||||
public class C_BP_Group_Acct_Copy extends SvrProcess
|
|
||||||
{
|
|
||||||
|
|
||||||
/*
|
|
||||||
* NOTE: The original oracle procedure C_BP_Group_Acct_Copy had a
|
|
||||||
* BP_Group_ID parameter for Direct Call not implemented in this class
|
|
||||||
*/
|
|
||||||
|
|
||||||
/** The Business Partner Group */
|
|
||||||
private int c_BP_Group_ID = -1;
|
|
||||||
/** The Record */
|
|
||||||
private int p_Record_ID = 0;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Prepare - e.g., get Parameters.
|
|
||||||
*/
|
|
||||||
protected void prepare()
|
|
||||||
{
|
|
||||||
ProcessInfoParameter[] para = getParameter();
|
|
||||||
for (int i = 0; i < para.length; i++)
|
|
||||||
{
|
|
||||||
String name = para[i].getParameterName();
|
|
||||||
if (para[i].getParameter() == null)
|
|
||||||
;
|
|
||||||
else if (name.equals("C_BP_Group_ID"))
|
|
||||||
c_BP_Group_ID = para[i].getParameterAsInt();
|
|
||||||
else
|
|
||||||
log.log(Level.SEVERE, "Unknown Parameter: " + name);
|
|
||||||
}
|
|
||||||
p_Record_ID = getRecord_ID();
|
|
||||||
} // prepare
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Process
|
|
||||||
* @return message
|
|
||||||
* @throws Exception
|
|
||||||
*/
|
|
||||||
protected String doIt() throws Exception
|
|
||||||
{
|
|
||||||
String sql;
|
|
||||||
String sqlupd;
|
|
||||||
String sqlins;
|
|
||||||
int cntu = 0;
|
|
||||||
int cnti = 0;
|
|
||||||
int totu = 0;
|
|
||||||
int toti = 0;
|
|
||||||
|
|
||||||
log.info("Copy and overwrite Accounts to products of this category");
|
|
||||||
|
|
||||||
sql = "SELECT C_RECEIVABLE_ACCT, C_PREPAYMENT_ACCT, C_ACCTSCHEMA_ID, C_BP_GROUP_ID, "
|
|
||||||
+ "V_PREPAYMENT_ACCT, V_LIABILITY_ACCT, V_LIABILITY_SERVICES_ACCT "
|
|
||||||
+ "FROM C_BP_Group_Acct "
|
|
||||||
+ "WHERE C_BP_Group_ID = " + c_BP_Group_ID;
|
|
||||||
PreparedStatement pstmt = null;
|
|
||||||
try
|
|
||||||
{
|
|
||||||
pstmt = DB.prepareStatement(sql, get_TrxName());
|
|
||||||
ResultSet rs = pstmt.executeQuery();
|
|
||||||
while (rs.next())
|
|
||||||
{
|
|
||||||
// Update existing Customers
|
|
||||||
sqlupd = "UPDATE C_BP_Customer_Acct "
|
|
||||||
+ "SET C_Receivable_Acct=" + rs.getInt("C_RECEIVABLE_ACCT") + ", "
|
|
||||||
+ "C_PrePayment_Acct=" + rs.getInt("C_PREPAYMENT_ACCT") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE C_BP_Customer_Acct.C_AcctSchema_ID=" + rs.getInt("C_ACCTSCHEMA_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM C_BPartner p "
|
|
||||||
+ "WHERE p.C_BPartner_ID=C_BP_Customer_Acct.C_BPartner_ID AND p.C_BP_Group_ID=" + rs.getInt("C_BP_GROUP_ID") + ")";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new Customer
|
|
||||||
sqlins = "INSERT INTO C_BP_Customer_Acct "
|
|
||||||
+ "(C_BPartner_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "C_Receivable_Acct, C_PrePayment_Acct) "
|
|
||||||
+ "SELECT p.C_BPartner_ID, " + rs.getInt("C_ACCTSCHEMA_ID") + ", "
|
|
||||||
+ "p.AD_Client_ID, p.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ rs.getInt("C_RECEIVABLE_ACCT") + ", " + rs.getInt("C_PREPAYMENT_ACCT") + " "
|
|
||||||
+ "FROM C_BPartner p "
|
|
||||||
+ "WHERE p.C_BP_Group_ID=" + rs.getInt("C_BP_GROUP_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM C_BP_Customer_Acct ca "
|
|
||||||
+ "WHERE ca.C_BPartner_ID=p.C_BPartner_ID AND ca.C_AcctSchema_ID=" + rs.getInt("C_ACCTSCHEMA_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Customers = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
// Update existing Vendors
|
|
||||||
sqlupd = "UPDATE C_BP_Vendor_Acct "
|
|
||||||
+ "SET V_Liability_Acct=" + rs.getInt("V_LIABILITY_ACCT") + ", "
|
|
||||||
+ "V_Liability_Services_Acct=" + rs.getInt("V_LIABILITY_SERVICES_ACCT") + ", "
|
|
||||||
+ "V_PrePayment_Acct=" + rs.getInt("V_PREPAYMENT_ACCT") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE C_BP_Vendor_Acct.C_AcctSchema_ID=" + rs.getInt("C_ACCTSCHEMA_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM C_BPartner p "
|
|
||||||
+ "WHERE p.C_BPartner_ID=C_BP_Vendor_Acct.C_BPartner_ID AND p.C_BP_Group_ID=" + rs.getInt("C_BP_GROUP_ID") + ")";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new Vendors
|
|
||||||
sqlins = "INSERT INTO C_BP_Vendor_Acct "
|
|
||||||
+ "(C_BPartner_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "V_Liability_Acct, V_Liability_Services_Acct, V_PrePayment_Acct) "
|
|
||||||
+ "SELECT p.C_BPartner_ID, " + rs.getInt("C_ACCTSCHEMA_ID") + ", "
|
|
||||||
+ "p.AD_Client_ID, p.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ rs.getInt("V_LIABILITY_ACCT") + ", " + rs.getInt("V_LIABILITY_SERVICES_ACCT")
|
|
||||||
+ ", " + rs.getInt("V_PREPAYMENT_ACCT") + " "
|
|
||||||
+ "FROM C_BPartner p "
|
|
||||||
+ "WHERE p.C_BP_Group_ID=" + rs.getInt("C_BP_GROUP_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM C_BP_Vendor_Acct va "
|
|
||||||
+ "WHERE va.C_BPartner_ID=p.C_BPartner_ID AND va.C_AcctSchema_ID=" + rs.getInt("C_ACCTSCHEMA_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Vendors = " + cntu + " / " + cnti);
|
|
||||||
|
|
||||||
}
|
|
||||||
rs.close();
|
|
||||||
pstmt.close();
|
|
||||||
pstmt = null;
|
|
||||||
log.fine("Committing ...");
|
|
||||||
DB.commit(true, get_TrxName());
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
log.log(Level.SEVERE, "adding missing elements", e);
|
|
||||||
}
|
|
||||||
try
|
|
||||||
{
|
|
||||||
if (pstmt != null)
|
|
||||||
pstmt.close();
|
|
||||||
pstmt = null;
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
pstmt = null;
|
|
||||||
}
|
|
||||||
|
|
||||||
return "@Created@=" + cnti + ":2, @Updated@=" + cntu + ":2";
|
|
||||||
} // doIt
|
|
||||||
|
|
||||||
} // C_BP_Group_Acct_Copy
|
|
||||||
|
|
@ -1,157 +0,0 @@
|
||||||
/******************************************************************************
|
|
||||||
* The contents of this file are subject to the Compiere License Version 1.1
|
|
||||||
* ("License"); You may not use this file except in compliance with the License
|
|
||||||
* You may obtain a copy of the License at http://www.compiere.org/license.html
|
|
||||||
* Software distributed under the License is distributed on an "AS IS" basis,
|
|
||||||
* WITHOUT WARRANTY OF ANY KIND, either express or implied. See the License for
|
|
||||||
* the specific language governing rights and limitations under the License.
|
|
||||||
* The Original Code is Compiere ERP & CRM Business Solution
|
|
||||||
* The Initial Developer of the Original Code is Jorg Janke and ComPiere, Inc.
|
|
||||||
* Portions created by Jorg Janke are Copyright (C) 1999-2005 Jorg Janke, parts
|
|
||||||
* created by ComPiere are Copyright (C) ComPiere, Inc.; All Rights Reserved.
|
|
||||||
* Portions created by Carlos Ruiz are Copyright (C) 2005 QSS Ltda.
|
|
||||||
* Contributor(s): Carlos Ruiz (globalqss)
|
|
||||||
*****************************************************************************/
|
|
||||||
package org.compiere.process;
|
|
||||||
|
|
||||||
import java.sql.*;
|
|
||||||
import java.util.logging.*;
|
|
||||||
|
|
||||||
import org.compiere.util.*;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Copy and overwrite Accounts to products of this category
|
|
||||||
*
|
|
||||||
* @author Carlos Ruiz (globalqss)
|
|
||||||
* @version $Id: M_Product_Category_Acct_Copy.java,v 1.0 2005/09/15 22:19:00 globalqss Exp $
|
|
||||||
*/
|
|
||||||
public class M_Product_Category_Acct_Copy extends SvrProcess
|
|
||||||
{
|
|
||||||
|
|
||||||
/*
|
|
||||||
* NOTE: The original oracle procedure M_Product_Category_Acct_Copy had a
|
|
||||||
* Product_Category_ID parameter for Direct Call not implemented in this class
|
|
||||||
*/
|
|
||||||
|
|
||||||
/** The Product Category */
|
|
||||||
private int m_Product_Category_ID = -1;
|
|
||||||
/** The Record */
|
|
||||||
private int p_Record_ID = 0;
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Prepare - e.g., get Parameters.
|
|
||||||
*/
|
|
||||||
protected void prepare()
|
|
||||||
{
|
|
||||||
ProcessInfoParameter[] para = getParameter();
|
|
||||||
for (int i = 0; i < para.length; i++)
|
|
||||||
{
|
|
||||||
String name = para[i].getParameterName();
|
|
||||||
if (para[i].getParameter() == null)
|
|
||||||
;
|
|
||||||
else if (name.equals("M_Product_Category_ID"))
|
|
||||||
m_Product_Category_ID = para[i].getParameterAsInt();
|
|
||||||
else
|
|
||||||
log.log(Level.SEVERE, "Unknown Parameter: " + name);
|
|
||||||
}
|
|
||||||
p_Record_ID = getRecord_ID();
|
|
||||||
} // prepare
|
|
||||||
|
|
||||||
/**
|
|
||||||
* Process
|
|
||||||
* @return message
|
|
||||||
* @throws Exception
|
|
||||||
*/
|
|
||||||
protected String doIt() throws Exception
|
|
||||||
{
|
|
||||||
String sql;
|
|
||||||
String sqlupd;
|
|
||||||
String sqlins;
|
|
||||||
int cntu = 0;
|
|
||||||
int cnti = 0;
|
|
||||||
int totu = 0;
|
|
||||||
int toti = 0;
|
|
||||||
|
|
||||||
log.info("Copy and overwrite Accounts to products of this category");
|
|
||||||
|
|
||||||
sql = "SELECT P_Revenue_Acct, P_Expense_Acct, P_Asset_Acct, P_CoGs_Acct, "
|
|
||||||
+ "P_PurchasePriceVariance_Acct, P_InvoicePriceVariance_Acct, P_TradeDiscountRec_Acct, "
|
|
||||||
+ "P_TradeDiscountGrant_Acct, C_AcctSchema_ID, M_Product_Category_ID "
|
|
||||||
+ "FROM M_Product_Category_Acct "
|
|
||||||
+ "WHERE M_Product_Category_ID = " + m_Product_Category_ID;
|
|
||||||
PreparedStatement pstmt = null;
|
|
||||||
try
|
|
||||||
{
|
|
||||||
pstmt = DB.prepareStatement(sql, get_TrxName());
|
|
||||||
ResultSet rs = pstmt.executeQuery();
|
|
||||||
while (rs.next())
|
|
||||||
{
|
|
||||||
// Update existing Products
|
|
||||||
sqlupd = "UPDATE M_Product_Acct "
|
|
||||||
+ "SET P_Revenue_Acct= " + rs.getInt("P_REVENUE_ACCT") + ", "
|
|
||||||
+ "P_Expense_Acct= " + rs.getInt("P_EXPENSE_ACCT") + ", "
|
|
||||||
+ "P_Asset_Acct= " + rs.getInt("P_ASSET_ACCT") + ", "
|
|
||||||
+ "P_CoGs_Acct= " + rs.getInt("P_COGS_ACCT") + ", "
|
|
||||||
+ "P_PurchasePriceVariance_Acct= " + rs.getInt("P_PURCHASEPRICEVARIANCE_ACCT") + ", "
|
|
||||||
+ "P_InvoicePriceVariance_Acct= " + rs.getInt("P_INVOICEPRICEVARIANCE_ACCT") + ", "
|
|
||||||
+ "P_TradeDiscountRec_Acct= " + rs.getInt("P_TRADEDISCOUNTREC_ACCT") + ", "
|
|
||||||
+ "P_TradeDiscountGrant_Acct= " + rs.getInt("P_TRADEDISCOUNTGRANT_ACCT") + ", "
|
|
||||||
+ "Updated=SysDate, "
|
|
||||||
+ "UpdatedBy=0 "
|
|
||||||
+ "WHERE M_Product_Acct.C_AcctSchema_ID= " + rs.getInt("C_ACCTSCHEMA_ID") + " "
|
|
||||||
+ "AND EXISTS (SELECT * FROM M_Product p "
|
|
||||||
+ "WHERE p.M_Product_ID=M_Product_Acct.M_Product_ID "
|
|
||||||
+ "AND p.M_Product_Category_ID= " + rs.getInt("M_PRODUCT_CATEGORY_ID") + ")";
|
|
||||||
cntu = DB.executeUpdate(sqlupd, get_TrxName());
|
|
||||||
totu += cntu;
|
|
||||||
// Insert new Products
|
|
||||||
sqlins = "INSERT INTO M_Product_Acct "
|
|
||||||
+ "(M_Product_ID, C_AcctSchema_ID, "
|
|
||||||
+ "AD_Client_ID, AD_Org_ID, IsActive, Created, CreatedBy, Updated, UpdatedBy, "
|
|
||||||
+ "P_Revenue_Acct, P_Expense_Acct, P_Asset_Acct, P_CoGs_Acct, "
|
|
||||||
+ "P_PurchasePriceVariance_Acct, P_InvoicePriceVariance_Acct, "
|
|
||||||
+ "P_TradeDiscountRec_Acct, P_TradeDiscountGrant_Acct) "
|
|
||||||
+ "SELECT p.M_Product_ID, " + rs.getInt("C_ACCTSCHEMA_ID") + ", "
|
|
||||||
+ "p.AD_Client_ID, p.AD_Org_ID, 'Y', SysDate, 0, SysDate, 0, "
|
|
||||||
+ rs.getInt("P_REVENUE_ACCT") + ", "
|
|
||||||
+ rs.getInt("P_EXPENSE_ACCT") + ", "
|
|
||||||
+ rs.getInt("P_ASSET_ACCT") + ", "
|
|
||||||
+ rs.getInt("P_COGS_ACCT") + ", "
|
|
||||||
+ rs.getInt("P_PURCHASEPRICEVARIANCE_ACCT") + ", "
|
|
||||||
+ rs.getInt("P_INVOICEPRICEVARIANCE_ACCT") + ", "
|
|
||||||
+ rs.getInt("P_TRADEDISCOUNTREC_ACCT") + ", "
|
|
||||||
+ rs.getInt("P_TRADEDISCOUNTGRANT_ACCT") + " "
|
|
||||||
+ "FROM M_Product p "
|
|
||||||
+ "WHERE p.M_Product_Category_ID=" + rs.getInt("M_PRODUCT_CATEGORY_ID") + " "
|
|
||||||
+ "AND NOT EXISTS (SELECT * FROM M_Product_Acct pa "
|
|
||||||
+ "WHERE pa.M_Product_ID=p.M_Product_ID "
|
|
||||||
+ "AND pa.C_AcctSchema_ID=" + rs.getInt("C_ACCTSCHEMA_ID") + ")";
|
|
||||||
cnti = DB.executeUpdate(sqlins, get_TrxName());
|
|
||||||
toti += cnti;
|
|
||||||
log.info("Product = " + cntu + " / " + cnti);
|
|
||||||
}
|
|
||||||
rs.close();
|
|
||||||
pstmt.close();
|
|
||||||
pstmt = null;
|
|
||||||
log.fine("Committing ...");
|
|
||||||
DB.commit(true, get_TrxName());
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
log.log(Level.SEVERE, "adding missing elements", e);
|
|
||||||
}
|
|
||||||
try
|
|
||||||
{
|
|
||||||
if (pstmt != null)
|
|
||||||
pstmt.close();
|
|
||||||
pstmt = null;
|
|
||||||
}
|
|
||||||
catch (Exception e)
|
|
||||||
{
|
|
||||||
pstmt = null;
|
|
||||||
}
|
|
||||||
|
|
||||||
return "@Created@=" + cnti + ", @Updated@=" + cntu;
|
|
||||||
} // doIt
|
|
||||||
|
|
||||||
} // M_Product_Category_Acct_Copy
|
|
||||||
|
|
@ -0,0 +1,33 @@
|
||||||
|
-- Update help for "C_AcctSchema_Default_Copy" process
|
||||||
|
UPDATE AD_PROCESS
|
||||||
|
SET classname = 'org.compiere.process.AcctSchemaDefaultCopy',
|
||||||
|
help = 'Either add missing accounts - or copy and overwrite all default accounts. If you copy and overwrite the current default values, you may have to repeat previous updates (e.g. set the bank account asset accounts, ...). If no Accounting Schema is selected all Accounting Schemas will be updated / inserted.'
|
||||||
|
WHERE AD_Process_ID=108;
|
||||||
|
|
||||||
|
-- Update Accounting Schema parameter for "C_AcctSchema_Default_Copy" process
|
||||||
|
UPDATE AD_PROCESS_PARA
|
||||||
|
SET ismandatory = 'Y'
|
||||||
|
WHERE ad_process_para_id= 669;
|
||||||
|
|
||||||
|
-- Update help for "M_Product_Category_Acct_Copy" process
|
||||||
|
UPDATE AD_PROCESS
|
||||||
|
SET classname = 'org.compiere.process.ProductCategoryAcctCopy',
|
||||||
|
help = 'If you copy and overwrite the current default values, you may have to repeat previous updates (e.g. set the revenue account, ...). If no Accounting Schema is selected all Accounting Schemas will be updated / inserted for products of this category.'
|
||||||
|
WHERE AD_Process_ID=140;
|
||||||
|
|
||||||
|
-- Update help for "M_Product_Category_Acct_Copy" process (SPANISH translation)
|
||||||
|
UPDATE AD_PROCESS_TRL
|
||||||
|
SET help ='El proceso de copiar cuentas tomará las cuentas definidas para una categoría de producto y las copiará a cualquier producto que que haga referencia a esta categoría. Si una cuenta existe a nivel de producto sera sobreescrita. Si no selecciona un Esquema Contable serán actualizados para todos los que estén definidos.'
|
||||||
|
WHERE AD_Process_ID=140
|
||||||
|
AND AD_LANGUAGE LIKE 'es_%';
|
||||||
|
|
||||||
|
-- Update Accounting Schema parameter for "M_Product_Category_Acct_Copy" process.
|
||||||
|
UPDATE AD_PROCESS_PARA
|
||||||
|
SET ismandatory = 'Y'
|
||||||
|
WHERE AD_Process_Para_ID=668;
|
||||||
|
|
||||||
|
UPDATE AD_PROCESS
|
||||||
|
SET classname = 'org.compiere.process.BPGroupAcctCopy'
|
||||||
|
WHERE AD_Process_ID=112;
|
||||||
|
|
||||||
|
COMMIT;
|
||||||
|
|
@ -0,0 +1,33 @@
|
||||||
|
-- Update help for "C_AcctSchema_Default_Copy" process
|
||||||
|
UPDATE AD_PROCESS
|
||||||
|
SET classname = 'org.compiere.process.AcctSchemaDefaultCopy',
|
||||||
|
help = 'Either add missing accounts - or copy and overwrite all default accounts. If you copy and overwrite the current default values, you may have to repeat previous updates (e.g. set the bank account asset accounts, ...). If no Accounting Schema is selected all Accounting Schemas will be updated / inserted.'
|
||||||
|
WHERE AD_Process_ID=108;
|
||||||
|
|
||||||
|
-- Update Accounting Schema parameter for "C_AcctSchema_Default_Copy" process
|
||||||
|
UPDATE AD_PROCESS_PARA
|
||||||
|
SET ismandatory = 'Y'
|
||||||
|
WHERE ad_process_para_id= 669;
|
||||||
|
|
||||||
|
-- Update help for "M_Product_Category_Acct_Copy" process
|
||||||
|
UPDATE AD_PROCESS
|
||||||
|
SET classname = 'org.compiere.process.ProductCategoryAcctCopy',
|
||||||
|
help = 'If you copy and overwrite the current default values, you may have to repeat previous updates (e.g. set the revenue account, ...). If no Accounting Schema is selected all Accounting Schemas will be updated / inserted for products of this category.'
|
||||||
|
WHERE AD_Process_ID=140;
|
||||||
|
|
||||||
|
-- Update help for "M_Product_Category_Acct_Copy" process (SPANISH translation)
|
||||||
|
UPDATE AD_PROCESS_TRL
|
||||||
|
SET help ='El proceso de copiar cuentas tomará las cuentas definidas para una categoría de producto y las copiará a cualquier producto que que haga referencia a esta categoría. Si una cuenta existe a nivel de producto sera sobreescrita. Si no selecciona un Esquema Contable serán actualizados para todos los que estén definidos.'
|
||||||
|
WHERE AD_Process_ID=140
|
||||||
|
AND AD_LANGUAGE LIKE 'es_%';
|
||||||
|
|
||||||
|
-- Update Accounting Schema parameter for "M_Product_Category_Acct_Copy" process.
|
||||||
|
UPDATE AD_PROCESS_PARA
|
||||||
|
SET ismandatory = 'Y'
|
||||||
|
WHERE AD_Process_Para_ID=668;
|
||||||
|
|
||||||
|
UPDATE AD_PROCESS
|
||||||
|
SET classname = 'org.compiere.process.BPGroupAcctCopy'
|
||||||
|
WHERE AD_Process_ID=112;
|
||||||
|
|
||||||
|
COMMIT;
|
||||||
Loading…
Reference in New Issue