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

IDEMPIERE-2354 Model Validator registered multiple times

This commit is contained in:
Carlos Ruiz 2014-12-26 11:03:30 -05:00
parent a297d16c4f
commit 42d684fa99
1 changed files with 153 additions and 179 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

210
org.adempiere.replication/src/org/adempiere/model/ExportModelValidator.java
View File

@ -25,10 +25,13 @@
* * * *
* Sponsors: * * Sponsors: *
* - e-Evolution (http://www.e-evolution.com) * * - e-Evolution (http://www.e-evolution.com) *
***********************************************************************/ **********************************************************************/
package org.adempiere.model; package org.adempiere.model;
import java.util.ArrayList;
import java.util.Hashtable;
import java.util.List;
import java.util.logging.Level; import java.util.logging.Level;
import org.adempiere.process.rpl.exp.ExportHelper; import org.adempiere.process.rpl.exp.ExportHelper;
@ -39,6 +42,7 @@ import org.compiere.model.MTable;
import org.compiere.model.ModelValidationEngine; import org.compiere.model.ModelValidationEngine;
import org.compiere.model.ModelValidator; import org.compiere.model.ModelValidator;
import org.compiere.model.PO; import org.compiere.model.PO;
import org.compiere.model.Query;
import org.compiere.model.X_AD_ReplicationDocument; import org.compiere.model.X_AD_ReplicationDocument;
import org.compiere.model.X_AD_ReplicationTable; import org.compiere.model.X_AD_ReplicationTable;
import org.compiere.util.CLogger; import org.compiere.util.CLogger;
@ -61,8 +65,7 @@ import org.compiere.util.Env;
* *
* @version $Id$ * @version $Id$
*/ */
public class ExportModelValidator implements ModelValidator public class ExportModelValidator implements ModelValidator {
{
/** Context variable which says if replication is enabled */ /** Context variable which says if replication is enabled */
public static final String CTX_IsReplicationEnabled = "#IsReplicationEnabled"; public static final String CTX_IsReplicationEnabled = "#IsReplicationEnabled";
@ -72,30 +75,18 @@ public class ExportModelValidator implements ModelValidator
/** Client */ /** Client */
private int m_AD_Client_ID = -1; private int m_AD_Client_ID = -1;
/** Organization */
private int m_AD_Org_ID = -1;
/** Role */
private int m_AD_Role_ID = -1;
/** User */
private int m_AD_User_ID = -1;
/** Replication Strategy **/
private int m_AD_ReplicationStrategy_ID = -1;
/** ModelValidationEngine engine **/ /** ModelValidationEngine engine **/
ModelValidationEngine m_engine = null; List<String> modelTables = new ArrayList<String>();
List<String> docTables = new ArrayList<String>();
/** Export Helper */ /* The Export Helpers per each replication strategy */
ExportHelper expHelper = null; Hashtable<Integer, ExportHelper> helpers = new Hashtable<Integer, ExportHelper>();
/** /**
* Constructor. * Constructor.
* The class is instantiated when logging in and client is selected/known * The class is instantiated when logging in and client is selected/known
*/ */
public ExportModelValidator () public ExportModelValidator () {
{
super (); super ();
} }
@ -104,21 +95,60 @@ public class ExportModelValidator implements ModelValidator
* @param engine validation engine * @param engine validation engine
* @param client client * @param client client
*/ */
public void initialize (ModelValidationEngine engine, MClient client) public void initialize (ModelValidationEngine engine, MClient client) {
{ if (client != null) {
m_engine = engine;
if (client != null)
{
m_AD_Client_ID = client.getAD_Client_ID(); m_AD_Client_ID = client.getAD_Client_ID();
if (log.isLoggable(Level.INFO)) log.info(client.toString()); if (log.isLoggable(Level.INFO)) log.info(client.toString());
} loadReplicationStrategy(engine);
else } else {
{
log.warning("Export Model Validator cannot be used as a global validator, it needs to be defined in a per-client (tenant) basis"); log.warning("Export Model Validator cannot be used as a global validator, it needs to be defined in a per-client (tenant) basis");
return; return;
} }
} }
public void loadReplicationStrategy(ModelValidationEngine engine) {
MClient client = MClient.get(Env.getCtx(), m_AD_Client_ID);
String where = "AD_ReplicationStrategy_ID IN (" +
"SELECT AD_ReplicationStrategy_ID FROM AD_Client WHERE AD_Client_ID=? " +
"UNION " +
"SELECT AD_ReplicationStrategy_ID FROM AD_Org WHERE AD_Client_ID=?)";
List<MReplicationStrategy> rss = new Query(Env.getCtx(), MReplicationStrategy.Table_Name, where, null)
.setOnlyActiveRecords(true)
.setParameters(m_AD_Client_ID, m_AD_Client_ID)
.list();
for (MReplicationStrategy rplStrategy : rss) {
ExportHelper expClientHelper = new ExportHelper(client, rplStrategy);
helpers.put(rplStrategy.getAD_ReplicationStrategy_ID(), expClientHelper);
// Add Tables
// We want to be informed when records in Replication tables are created/updated/deleted!
for (X_AD_ReplicationTable rplTable : rplStrategy.getReplicationTables()) {
if ( X_AD_ReplicationTable.REPLICATIONTYPE_Merge.equals(rplTable.getReplicationType())
|| X_AD_ReplicationTable.REPLICATIONTYPE_Broadcast.equals(rplTable.getReplicationType())
|| X_AD_ReplicationTable.REPLICATIONTYPE_Reference.equals(rplTable.getReplicationType()))
{
String tableName = MTable.getTableName(client.getCtx(), rplTable.getAD_Table_ID());
if (! modelTables.contains(tableName)) {
engine.addModelChange(tableName, this);
modelTables.add(tableName);
}
}
}
// Add Documents
// We want to be informed when Replication documents are created/updated/deleted!
for (X_AD_ReplicationDocument rplDocument : rplStrategy.getReplicationDocuments()) {
if ( X_AD_ReplicationDocument.REPLICATIONTYPE_Merge.equals(rplDocument.getReplicationType())
|| X_AD_ReplicationDocument.REPLICATIONTYPE_Reference.equals(rplDocument.getReplicationType()))
{
String tableName = MTable.getTableName(client.getCtx(), rplDocument.getAD_Table_ID());
if (! docTables.contains(tableName)) {
engine.addDocValidate(tableName, this);
docTables.add(tableName);
}
}
}
}
}
/** /**
* Model Change of a monitored Table. * Model Change of a monitored Table.
* Called after PO.beforeSave/PO.beforeDelete * Called after PO.beforeSave/PO.beforeDelete
@ -127,19 +157,18 @@ public class ExportModelValidator implements ModelValidator
* @return error message or null * @return error message or null
* @exception Exception if the recipient wishes the change to be not accept. * @exception Exception if the recipient wishes the change to be not accept.
*/ */
public String modelChange (PO po, int type) throws Exception public String modelChange (PO po, int type) throws Exception {
{
//String Mode = "Table";
if (log.isLoggable(Level.INFO)) log.info("po.get_TableName() = " + po.get_TableName()); if (log.isLoggable(Level.INFO)) log.info("po.get_TableName() = " + po.get_TableName());
int rsID = getReplicationStrategy(po);
if (rsID > 0) {
ExportHelper expHelper = helpers.get(rsID);
if (expHelper != null) { if (expHelper != null) {
if ( type == TYPE_AFTER_CHANGE if ( type == TYPE_AFTER_CHANGE
|| type == TYPE_AFTER_NEW || type == TYPE_AFTER_NEW
|| type == TYPE_BEFORE_DELETE) // After Change or After New || type == TYPE_BEFORE_DELETE) {
{
X_AD_ReplicationTable replicationTable = MReplicationStrategy.getReplicationTable( X_AD_ReplicationTable replicationTable = MReplicationStrategy.getReplicationTable(
po.getCtx(), m_AD_ReplicationStrategy_ID, po.get_Table_ID()); po.getCtx(), rsID, po.get_Table_ID());
if (replicationTable != null) if (replicationTable != null) {
{
expHelper.exportRecord( expHelper.exportRecord(
po, po,
MReplicationStrategy.REPLICATION_TABLE, MReplicationStrategy.REPLICATION_TABLE,
@ -148,7 +177,7 @@ public class ExportModelValidator implements ModelValidator
} }
} }
} }
}
return null; return null;
} }
@ -161,10 +190,12 @@ public class ExportModelValidator implements ModelValidator
* @return error message or null * @return error message or null
* @throws Exception * @throws Exception
*/ */
public String docValidate (PO po, int type) public String docValidate (PO po, int type) {
{
if (log.isLoggable(Level.INFO)) log.info("Replicate the Document = " + po.get_TableName() + " with Type = " + type); if (log.isLoggable(Level.INFO)) log.info("Replicate the Document = " + po.get_TableName() + " with Type = " + type);
String result = null; String result = null;
int rsID = getReplicationStrategy(po);
if (rsID > 0) {
ExportHelper expHelper = helpers.get(rsID);
if (expHelper != null) { if (expHelper != null) {
try { try {
if ( type == TIMING_AFTER_COMPLETE if ( type == TIMING_AFTER_COMPLETE
@ -173,22 +204,17 @@ public class ExportModelValidator implements ModelValidator
|| type == TIMING_AFTER_VOID || type == TIMING_AFTER_VOID
|| type == TIMING_AFTER_REACTIVATE || type == TIMING_AFTER_REACTIVATE
//|| type == TIMING_AFTER_PREPARE //|| type == TIMING_AFTER_PREPARE
) ) {
{
X_AD_ReplicationDocument replicationDocument = null; X_AD_ReplicationDocument replicationDocument = null;
int C_DocType_ID = po.get_ValueAsInt("C_DocType_ID"); int C_DocType_ID = po.get_ValueAsInt("C_DocType_ID");
if (C_DocType_ID > 0) if (C_DocType_ID > 0) {
{
replicationDocument = MReplicationStrategy.getReplicationDocument( replicationDocument = MReplicationStrategy.getReplicationDocument(
po.getCtx(), m_AD_ReplicationStrategy_ID, po.get_Table_ID(), C_DocType_ID); po.getCtx(), rsID, po.get_Table_ID(), C_DocType_ID);
} } else {
else
{
replicationDocument = MReplicationStrategy.getReplicationDocument( replicationDocument = MReplicationStrategy.getReplicationDocument(
po.getCtx(), m_AD_ReplicationStrategy_ID, po.get_Table_ID()); po.getCtx(), rsID, po.get_Table_ID());
} }
if (replicationDocument != null) { if (replicationDocument != null) {
expHelper.exportRecord( expHelper.exportRecord(
po, po,
@ -196,16 +222,29 @@ public class ExportModelValidator implements ModelValidator
replicationDocument.getReplicationType(), replicationDocument.getReplicationType(),
type); type);
} }
} }
} catch (Exception e) { } catch (Exception e) {
e.printStackTrace(); e.printStackTrace();
result = e.toString(); result = e.toString();
} }
} }
}
return result; return result;
} }
private int getReplicationStrategy(PO po) {
int rsID = -1;
int orgID = po.getAD_Org_ID();
if (orgID > 0) {
rsID = MOrg.get(po.getCtx(), orgID).getAD_ReplicationStrategy_ID();
}
if (rsID <= 0) {
int clientID = po.getAD_Client_ID();
rsID = MClient.get(Env.getCtx(), clientID).getAD_ReplicationStrategy_ID();
}
return rsID;
}
/** /**
* User Login. * User Login.
* Called when preferences are set * Called when preferences are set
@ -214,89 +253,24 @@ public class ExportModelValidator implements ModelValidator
* @param AD_User_ID user * @param AD_User_ID user
* @return error message or null * @return error message or null
*/ */
public String login (int AD_Org_ID, int AD_Role_ID, int AD_User_ID) public String login (int AD_Org_ID, int AD_Role_ID, int AD_User_ID) {
{
Env.setContext(Env.getCtx(), CTX_IsReplicationEnabled, true); Env.setContext(Env.getCtx(), CTX_IsReplicationEnabled, true);
m_AD_Org_ID = AD_Org_ID;
m_AD_Role_ID = AD_Role_ID;
m_AD_User_ID = AD_User_ID;
if (log.isLoggable(Level.INFO)){
log.info("AD_Org_ID =" + m_AD_Org_ID);
log.info("AD_Role_ID =" + m_AD_Role_ID);
log.info("AD_User_ID =" + m_AD_User_ID);}
loadReplicationStrategy();
return null; return null;
} }
/** /**
* Get Client to be monitored * Get Client to be monitored
* @return AD_Client_ID client * @return AD_Client_ID client
*/ */
public int getAD_Client_ID() public int getAD_Client_ID() {
{
return m_AD_Client_ID; return m_AD_Client_ID;
} }
public void loadReplicationStrategy()
{
MClient client = MClient.get(Env.getCtx(), m_AD_Client_ID);
MReplicationStrategy rplStrategy = null;
m_AD_ReplicationStrategy_ID = MOrg.get(client.getCtx(),m_AD_Org_ID).getAD_ReplicationStrategy_ID();
if(m_AD_ReplicationStrategy_ID <= 0)
{
m_AD_ReplicationStrategy_ID = client.getAD_ReplicationStrategy_ID();
if (log.isLoggable(Level.INFO)) log.info("client.getAD_ReplicationStrategy_ID() = " + m_AD_ReplicationStrategy_ID);
}
if (m_AD_ReplicationStrategy_ID > 0) {
rplStrategy = new MReplicationStrategy(client.getCtx(), m_AD_ReplicationStrategy_ID, null);
if(!rplStrategy.isActive())
{
return;
}
expHelper = new ExportHelper(client, rplStrategy);
}
// Add Tables
// We want to be informed when records in Replication tables are created/updated/deleted!
//engine.addModelChange(MBPartner.Table_Name, this);
//engine.addModelChange(MOrder.Table_Name, this);
//engine.addModelChange(MOrderLine.Table_Name, this);
if (rplStrategy != null) {
for (X_AD_ReplicationTable rplTable : rplStrategy.getReplicationTables()) {
if (X_AD_ReplicationTable.REPLICATIONTYPE_Merge.equals(rplTable.getReplicationType())
|| X_AD_ReplicationTable.REPLICATIONTYPE_Broadcast.equals(rplTable.getReplicationType())
|| X_AD_ReplicationTable.REPLICATIONTYPE_Reference.equals(rplTable.getReplicationType()))
{
String tableName = MTable.getTableName(client.getCtx(), rplTable.getAD_Table_ID());
m_engine.addModelChange(tableName, this);
}
}
}
// Add Documents
// We want to be informed when Replication documents are created/updated/deleted!
if (rplStrategy != null) {
for (X_AD_ReplicationDocument rplDocument : rplStrategy.getReplicationDocuments()) {
if (X_AD_ReplicationDocument.REPLICATIONTYPE_Merge.equals(rplDocument.getReplicationType())
|| X_AD_ReplicationDocument.REPLICATIONTYPE_Reference.equals(rplDocument.getReplicationType()))
{
String tableName = MTable.getTableName(client.getCtx(), rplDocument.getAD_Table_ID());
m_engine.addDocValidate(tableName, this);
}
}
}
}
/** /**
* String Representation * String Representation
* @return info * @return info
*/ */
public String toString () public String toString () {
{
StringBuilder sb = new StringBuilder (ExportModelValidator.class.getName()); StringBuilder sb = new StringBuilder (ExportModelValidator.class.getName());
return sb.toString(); return sb.toString();
} }