From e017046dac29d4dde2211178118ee2990e25ca41 Mon Sep 17 00:00:00 2001
From: hengsin <hengsin@gmail.com>
Date: Thu, 10 Dec 2020 18:54:39 +0800
Subject: [PATCH] IDEMPIERE-4590 Scheduler Window: Start Scheduler action
 change AD_Client_ID to 0 when HazelCast Service is Down/Disable (#449)

---
 .../compiere/server/AdempiereServerMgr.java   | 30 +++++++++++++++----
 .../webui/scheduler/SchedulerStateEditor.java |  2 +-
 2 files changed, 26 insertions(+), 6 deletions(-)

diff --git a/org.adempiere.server/src/main/server/org/compiere/server/AdempiereServerMgr.java b/org.adempiere.server/src/main/server/org/compiere/server/AdempiereServerMgr.java
index fad431ff5f..75979de059 100644
--- a/org.adempiere.server/src/main/server/org/compiere/server/AdempiereServerMgr.java
+++ b/org.adempiere.server/src/main/server/org/compiere/server/AdempiereServerMgr.java
@@ -31,6 +31,7 @@ import org.adempiere.base.Core;
 import org.adempiere.base.Service;
 import org.adempiere.server.AdempiereServerActivator;
 import org.adempiere.server.IServerFactory;
+import org.adempiere.util.ServerContext;
 import org.compiere.Adempiere;
 import org.compiere.model.AdempiereProcessor;
 import org.compiere.model.MScheduler;
@@ -344,16 +345,23 @@ public class AdempiereServerMgr implements ServiceTrackerCustomizer<IServerFacto
 	{
 		log.info ("");
 		LocalServerController[] servers = getInActive();
+		Properties currentContext = ServerContext.getCurrentInstance();
 		for (int i = 0; i < servers.length; i++)
 		{
 			LocalServerController server = servers[i];
+			Properties temp = null;
 			try
 			{
 				if (server.scheduleFuture != null && !server.scheduleFuture.isDone())
 					continue;
 				//	Do start
 				//	replace
-				Env.setContext(Env.getCtx(), Env.AD_CLIENT_ID, server.getServer().getModel().getAD_Client_ID());
+				if (Env.getAD_Client_ID(currentContext) != server.getServer().getModel().getAD_Client_ID())
+				{
+					temp = new Properties(currentContext);
+					Env.setContext(temp, Env.AD_CLIENT_ID, server.getServer().getModel().getAD_Client_ID());
+					ServerContext.setCurrentInstance(temp);
+				}
 				server.getServer().recalculateSleepMS();
 				server.start();
 			}
@@ -361,8 +369,12 @@ public class AdempiereServerMgr implements ServiceTrackerCustomizer<IServerFacto
 			{
 				log.log(Level.SEVERE, "Server: " + server, e);
 			}
-		}	//	for all servers
-		Env.setContext(Env.getCtx(), Env.AD_CLIENT_ID, 0);
+			finally
+			{
+				if (temp != null)
+					ServerContext.setCurrentInstance(currentContext);
+			}
+		}	//	for all servers		
 		
 		//	Final Check
 		int noRunning = 0;
@@ -407,10 +419,17 @@ public class AdempiereServerMgr implements ServiceTrackerCustomizer<IServerFacto
 		if (server.scheduleFuture != null && !server.scheduleFuture.isDone())
 			return "Server is already running";
 		
+		Properties currentContext = ServerContext.getCurrentInstance();
+		Properties temp = null;
 		try
 		{
 			//	replace
-			Env.setContext(Env.getCtx(), Env.AD_CLIENT_ID, server.getServer().getModel().getAD_Client_ID());
+			if (Env.getAD_Client_ID(currentContext) != server.getServer().getModel().getAD_Client_ID())
+			{
+				temp = new Properties(currentContext);
+				Env.setContext(temp, Env.AD_CLIENT_ID, server.getServer().getModel().getAD_Client_ID());
+				ServerContext.setCurrentInstance(temp);
+			}
 			server.getServer().recalculateSleepMS();
 			server.start();
 		}
@@ -421,7 +440,8 @@ public class AdempiereServerMgr implements ServiceTrackerCustomizer<IServerFacto
 		}
 		finally
 		{
-			Env.setContext(Env.getCtx(), Env.AD_CLIENT_ID, 0);
+			if (temp != null)
+				ServerContext.setCurrentInstance(currentContext);
 		}
 		if (log.isLoggable(Level.INFO)) log.info(server.toString());
 		return (server.scheduleFuture != null && !server.scheduleFuture.isDone()) ? null : "Failed to start server"; 
diff --git a/org.adempiere.ui.zk/WEB-INF/src/org/adempiere/webui/scheduler/SchedulerStateEditor.java b/org.adempiere.ui.zk/WEB-INF/src/org/adempiere/webui/scheduler/SchedulerStateEditor.java
index 9268d61d52..fc375b55eb 100644
--- a/org.adempiere.ui.zk/WEB-INF/src/org/adempiere/webui/scheduler/SchedulerStateEditor.java
+++ b/org.adempiere.ui.zk/WEB-INF/src/org/adempiere/webui/scheduler/SchedulerStateEditor.java
@@ -332,7 +332,7 @@ public class SchedulerStateEditor extends WEditor {
 		schedulerState=0;
 		MScheduler scheduler = new MScheduler(Env.getCtx(), getAD_Scheduler_ID(), null);
 		IServerManager serverMgr = getServerMgr();
-		schedulerState = serverMgr.getServerStatus(scheduler.getServerID());
+		schedulerState = serverMgr != null ? serverMgr.getServerStatus(scheduler.getServerID()) : -1;
 		String label = null;
 		if (schedulerState == IServerManager.SERVER_STATE_NOT_SCHEDULE)
 			label = Msg.getMsg(Env.getCtx(), "SchedulerNotSchedule");