From de70b563f3f9bf70a3a758572185bb764a87adc3 Mon Sep 17 00:00:00 2001
From: Heng Sin Low <hengsin@gmail.com>
Date: Mon, 17 Sep 2007 05:05:34 +0000
Subject: [PATCH] * [ 1796015 ] Add notification for schedule process run.

---
 .../server/org/compiere/server/Scheduler.java | 58 ++++++++++++++++++-
 1 file changed, 57 insertions(+), 1 deletion(-)

diff --git a/serverRoot/src/main/server/org/compiere/server/Scheduler.java b/serverRoot/src/main/server/org/compiere/server/Scheduler.java
index 174d24df3d..75230bbc90 100644
--- a/serverRoot/src/main/server/org/compiere/server/Scheduler.java
+++ b/serverRoot/src/main/server/org/compiere/server/Scheduler.java
@@ -166,7 +166,63 @@ public class Scheduler extends AdempiereServer
 		pi.setAD_User_ID(m_model.getUpdatedBy());
 		pi.setAD_Client_ID(m_model.getAD_Client_ID());
 		pi.setAD_PInstance_ID(pInstance.getAD_PInstance_ID());
-		process.processIt(pi, m_trx);
+		//notify supervisor if error
+		if ( !process.processIt(pi, m_trx) ) 
+		{
+			int supervisor = m_model.getSupervisor_ID();
+			if (supervisor > 0) 
+			{
+				MUser user = new MUser(getCtx(), supervisor, null);
+				String type = user.getNotificationType();
+				boolean email = X_AD_User.NOTIFICATIONTYPE_EMail.equals(type) ||
+					X_AD_User.NOTIFICATIONTYPE_EMailPlusNotice.equals(type);
+				boolean notice = X_AD_User.NOTIFICATIONTYPE_Notice.equals(type) ||
+					X_AD_User.NOTIFICATIONTYPE_EMailPlusNotice.equals(type);
+				if (email) 
+				{
+					MClient client = MClient.get(m_model.getCtx(), m_model.getAD_Client_ID());
+					client.sendEMail(supervisor, process.getName(), pi.getSummary(), null);
+				}
+				if (notice) {
+					int AD_Message_ID = 442; //ProcessRunError
+					MNote note = new MNote(getCtx(), 
+							AD_Message_ID, supervisor, m_trx.getTrxName());
+					note.setClientOrg(m_model.getAD_Client_ID(), m_model.getAD_Org_ID());
+					note.setTextMsg(pi.getSummary());
+					//note.setDescription();
+					note.setRecord(X_AD_PInstance.Table_ID, pi.getAD_PInstance_ID());
+					note.save();
+				}
+			}
+		} 
+		else 
+		{
+			Integer[] userIDs = m_model.getRecipientAD_User_IDs();
+			for (int i = 0; i < userIDs.length; i++) 
+			{
+				MUser user = new MUser(getCtx(), userIDs[i].intValue(), null);
+				String type = user.getNotificationType();
+				boolean email = X_AD_User.NOTIFICATIONTYPE_EMail.equals(type) ||
+					X_AD_User.NOTIFICATIONTYPE_EMailPlusNotice.equals(type);
+				boolean notice = X_AD_User.NOTIFICATIONTYPE_Notice.equals(type) ||
+					X_AD_User.NOTIFICATIONTYPE_EMailPlusNotice.equals(type);
+				if (email) 
+				{
+					MClient client = MClient.get(m_model.getCtx(), m_model.getAD_Client_ID());
+					client.sendEMail(userIDs[i].intValue(), process.getName(), pi.getSummary(), null);
+				}
+				if (notice) {
+					int AD_Message_ID = 441; //ProcessOK
+					MNote note = new MNote(getCtx(), 
+							AD_Message_ID, userIDs[i].intValue(), m_trx.getTrxName());
+					note.setClientOrg(m_model.getAD_Client_ID(), m_model.getAD_Org_ID());
+					note.setTextMsg(pi.getSummary());
+					//note.setDescription();
+					note.setRecord(X_AD_PInstance.Table_ID, pi.getAD_PInstance_ID());
+					note.save();
+				}
+			}
+		}
 		return pi.getSummary();
 	}	//	runProcess