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

FR [ 2788278 ] Data Import Validator - migrate core processes 

https://sourceforge.net/tracker/?func=detail&aid=2788278&group_id=176962&atid=879335
Implemented for ImportProduct
This commit is contained in:
Carlos Ruiz 2011-03-26 01:34:58 -05:00
parent 0edb77c973
commit b994e41c9e
1 changed files with 27 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
org.adempiere.base.process/src/org/compiere/process/ImportProduct.java
View File

@ -23,8 +23,11 @@ import java.sql.SQLException;
import java.sql.Timestamp; import java.sql.Timestamp;
import java.util.logging.Level; import java.util.logging.Level;
import org.adempiere.model.ImportValidator;
import org.adempiere.process.ImportProcess;
import org.compiere.model.MProduct; import org.compiere.model.MProduct;
import org.compiere.model.MProductPrice; import org.compiere.model.MProductPrice;
import org.compiere.model.ModelValidationEngine;
import org.compiere.model.X_I_Product; import org.compiere.model.X_I_Product;
import org.compiere.util.DB; import org.compiere.util.DB;
@ -33,8 +36,12 @@ import org.compiere.util.DB;
* *
* @author Jorg Janke * @author Jorg Janke
* @version $Id: ImportProduct.java,v 1.3 2006/07/30 00:51:01 jjanke Exp $ * @version $Id: ImportProduct.java,v 1.3 2006/07/30 00:51:01 jjanke Exp $
*
* @author Carlos Ruiz, globalqss
* <li>FR [ 2788278 ] Data Import Validator - migrate core processes
* https://sourceforge.net/tracker/?func=detail&aid=2788278&group_id=176962&atid=879335
*/ */
public class ImportProduct extends SvrProcess public class ImportProduct extends SvrProcess implements ImportProcess
{ {
/** Client to be imported to */ /** Client to be imported to */
private int m_AD_Client_ID = 0; private int m_AD_Client_ID = 0;
@ -78,7 +85,7 @@ public class ImportProduct extends SvrProcess
{ {
StringBuffer sql = null; StringBuffer sql = null;
int no = 0; int no = 0;
String clientCheck = " AND AD_Client_ID=" + m_AD_Client_ID; String clientCheck = getWhereClause();
// **** Prepare **** // **** Prepare ****
@ -107,6 +114,8 @@ public class ImportProduct extends SvrProcess
no = DB.executeUpdate(sql.toString(), get_TrxName()); no = DB.executeUpdate(sql.toString(), get_TrxName());
log.info("Reset=" + no); log.info("Reset=" + no);
ModelValidationEngine.get().fireImportValidate(this, null, null, ImportValidator.TIMING_BEFORE_VALIDATE);
// Set Optional BPartner // Set Optional BPartner
sql = new StringBuffer ("UPDATE I_Product i " sql = new StringBuffer ("UPDATE I_Product i "
+ "SET C_BPartner_ID=(SELECT C_BPartner_ID FROM C_BPartner p" + "SET C_BPartner_ID=(SELECT C_BPartner_ID FROM C_BPartner p"
@ -378,6 +387,8 @@ public class ImportProduct extends SvrProcess
} }
log.fine("C_TaxCategory_ID=" + C_TaxCategory_ID); log.fine("C_TaxCategory_ID=" + C_TaxCategory_ID);
ModelValidationEngine.get().fireImportValidate(this, null, null, ImportValidator.TIMING_AFTER_VALIDATE);
commitEx(); commitEx();
// ------------------------------------------------------------------- // -------------------------------------------------------------------
@ -484,6 +495,7 @@ public class ImportProduct extends SvrProcess
{ {
MProduct product = new MProduct(imp); MProduct product = new MProduct(imp);
product.setC_TaxCategory_ID(C_TaxCategory_ID); product.setC_TaxCategory_ID(C_TaxCategory_ID);
ModelValidationEngine.get().fireImportValidate(this, imp, product, ImportValidator.TIMING_AFTER_IMPORT);
if (product.save()) if (product.save())
{ {
M_Product_ID = product.getM_Product_ID(); M_Product_ID = product.getM_Product_ID();
@ -619,6 +631,7 @@ public class ImportProduct extends SvrProcess
pp = new MProductPrice (getCtx(), pp = new MProductPrice (getCtx(),
p_M_PriceList_Version_ID, M_Product_ID, get_TrxName()); p_M_PriceList_Version_ID, M_Product_ID, get_TrxName());
pp.setPrices(PriceList, PriceStd, PriceLimit); pp.setPrices(PriceList, PriceStd, PriceLimit);
ModelValidationEngine.get().fireImportValidate(this, imp, pp, ImportValidator.TIMING_AFTER_IMPORT);
pp.save(); pp.save();
} }
} }
@ -658,4 +671,16 @@ public class ImportProduct extends SvrProcess
return ""; return "";
} // doIt } // doIt
@Override
public String getImportTableName() {
return X_I_Product.Table_Name;
}
@Override
public String getWhereClause() {
return " AND AD_Client_ID=" + m_AD_Client_ID;
}
} // ImportProduct } // ImportProduct