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

Error when a Document is revert the Replication 

kind regards
Victor Perez
www.e-evolution.com
Link to SF Tracker: http://sourceforge.net/support/tracker.php?aid=3015672
This commit is contained in:
vpj-cd 2010-06-14 02:23:15 +00:00
parent db2dba8a3f
commit ecda1c1f65
1 changed files with 33 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
base/src/org/adempiere/process/rpl/imp/ImportHelper.java
View File

@ -88,9 +88,6 @@ public class ImportHelper {
/** Set change PO */
boolean isChanged= false;
/** ReplicationEvent **/
int ReplicationMode = -1;
/** Context */
private Properties ctx = null;
@ -130,7 +127,7 @@ public class ImportHelper {
throw new Exception(Msg.getMsg(ctx, "XMLVersionAttributeMandatory"));
}
///Getting Attributes.
ReplicationMode = new Integer(rootElement.getAttribute("ReplicationMode"));
int ReplicationMode = new Integer(rootElement.getAttribute("ReplicationMode"));
String ReplicationType = rootElement.getAttribute("ReplicationType");
int ReplicationEvent = new Integer(rootElement.getAttribute("ReplicationEvent"));
@ -176,6 +173,8 @@ public class ImportHelper {
if(po != null)
{
Env.setContext(po.getCtx(), "#AD_Client_ID", po.getAD_Client_ID());
if(MReplicationStrategy.REPLICATION_TABLE==ReplicationMode)
{
// Here must invoke other method else we get cycle...
@ -223,17 +222,37 @@ public class ImportHelper {
&& X_AD_ReplicationDocument.REPLICATIONTYPE_Merge.equals(ReplicationType)
&& po instanceof DocAction)
{
Env.setContext(po.getCtx(), "#AD_Client_ID", po.getAD_Client_ID());
DocAction document = (DocAction)po;
if(!document.processIt(document.getDocAction()))
String action = document.getDocAction();
String status = document.getDocStatus();
log.info("Document:"+document.toString() + " DocStauts:" + status + " DocAction:"+action);
if(ModelValidator.TIMING_AFTER_REVERSECORRECT==ReplicationEvent)
{
if(status.equals(DocAction.STATUS_Reversed) && action.equals(DocAction.ACTION_None))
{
po.saveEx();
return;
}
}
if( (action.equals(DocAction.ACTION_Complete) && status.equals(DocAction.STATUS_InProgress))
|| (action.equals(DocAction.ACTION_Close) && status.equals(DocAction.STATUS_Completed)))
{
if(!document.processIt(action))
{
log.info("PO.toString() = can not " + po.get_Value("DocAction"));
}
po.saveEx();
}
else
{
po.saveEx();
return;
}
}
}
result.append("Save Successful ;");
ReplicationMode = -1;
}
/**
@ -346,7 +365,7 @@ public class ImportHelper {
else if (MEXPFormatLine.TYPE_EmbeddedEXPFormat.equals(line.getType()))
{
if(po.is_Changed() && MReplicationStrategy.REPLICATION_DOCUMENT == ReplicationMode)
if(po.is_Changed())
{
isChanged = true;
po.saveReplica(true);