From 2c443e1bd5482ba7dcae6029e7a42ab6f6102e4a Mon Sep 17 00:00:00 2001
From: Carlos Ruiz <carg67@gmail.com>
Date: Wed, 17 Dec 2014 18:26:14 -0500
Subject: [PATCH] IDEMPIERE-2357 Contextual Variables on Replication Processor
 are missing / integrate fix thanks to Tomas Svikruha (tsvikruha)

---
 .../compiere/server/ReplicationProcessor.java | 24 +++++++++++++++++++
 1 file changed, 24 insertions(+)

diff --git a/org.adempiere.replication.server/src/org/compiere/server/ReplicationProcessor.java b/org.adempiere.replication.server/src/org/compiere/server/ReplicationProcessor.java
index a86279ab57..542d25058c 100644
--- a/org.adempiere.replication.server/src/org/compiere/server/ReplicationProcessor.java
+++ b/org.adempiere.replication.server/src/org/compiere/server/ReplicationProcessor.java
@@ -34,7 +34,9 @@ import java.util.logging.Level;
 import org.adempiere.server.rpl.IImportProcessor;
 import org.compiere.model.AdempiereProcessor;
 import org.compiere.model.MClient;
+import org.compiere.model.MOrgInfo;
 import org.compiere.model.X_IMP_Processor_Type;
+import org.compiere.util.Env;
 import org.compiere.util.TimeUtil;
 import org.compiere.server.AdempiereServer;
 import org.compiere.model.MIMPProcessor;
@@ -95,6 +97,16 @@ public class ReplicationProcessor extends AdempiereServer {
 		else 
 		{
 		    // process is not started!
+			
+			// Prepare a ctx
+			Env.setContext(mImportProcessor.getCtx(), "#AD_Client_ID", mImportProcessor.getAD_Client_ID());
+			Env.setContext(mImportProcessor.getCtx(), "#AD_Org_ID", mImportProcessor.getAD_Org_ID());
+			if (mImportProcessor.getAD_Org_ID() != 0) {
+				MOrgInfo schedorg = MOrgInfo.get(getCtx(), mImportProcessor.getAD_Org_ID(), null);
+				if (schedorg.getM_Warehouse_ID() > 0)
+					Env.setContext(mImportProcessor.getCtx(), "#M_Warehouse_ID", schedorg.getM_Warehouse_ID());
+				}
+			Env.setContext(mImportProcessor.getCtx(), "#AD_User_ID", getAD_User_ID());
 		    
 		    m_summary = new StringBuffer();
 		    String trxName = mImportProcessor.get_TrxName();
@@ -148,6 +160,18 @@ public class ReplicationProcessor extends AdempiereServer {
 		}
 	}
 
+	protected int getAD_User_ID() {
+		int AD_User_ID;
+		if (mImportProcessor.getCreatedBy() > 0)
+			AD_User_ID = mImportProcessor.getCreatedBy();
+		else if (mImportProcessor.getUpdatedBy() > 0)
+			AD_User_ID = mImportProcessor.getUpdatedBy();
+		else
+			AD_User_ID = 100; //fall back to SuperUser
+			
+		return AD_User_ID;
+	}
+	
 	@Override
 	public String getServerInfo()
 	{