escalationtests.cs

drools 一个开放源码的规则引擎

using System;
using NUnit.Framework;
using System.IO;
using System.Threading;
using org.drools.@event;

namespace org.drools.dotnet.examples.escalation
{
	[TestFixture]
	public class EscalationTests
	{
		[Test]
		public void TestEscalationExample()
		{
			RuleBase ruleBase = RuleBaseLoader.LoadFromUri(new Uri(
				"./drls/escalation.csharp.drl.xml", UriKind.Relative));
			WorkingMemory workingMemory = ruleBase.newWorkingMemory();
			workingMemory.addEventListener(new DebugWorkingMemoryEventListener());

			TroubleTicket bobTicket = new TroubleTicket("bob");
			TroubleTicket daveTicket = new TroubleTicket("dave");

			Console.WriteLine("----------------------------------------");
			Console.WriteLine("    PRE");
			Console.WriteLine("----------------------------------------");
			Console.WriteLine(bobTicket.ToString());
			Console.WriteLine(daveTicket.ToString());
			Console.WriteLine("----------------------------------------");

			workingMemory.assertObject(daveTicket);
			workingMemory.assertObject(bobTicket);
			Console.WriteLine("----------------------------------------");
			Console.WriteLine("    POST ASSERT");
			Console.WriteLine("----------------------------------------");
			Console.WriteLine(bobTicket.ToString());
			Console.WriteLine(daveTicket.ToString());
			Console.WriteLine("----------------------------------------");

			workingMemory.fireAllRules();
			Thread.Sleep(1000);
			Console.WriteLine("----------------------------------------");
			Console.WriteLine("    POST FIRE ALL RULES");
			Console.WriteLine("----------------------------------------");
			Console.WriteLine(bobTicket.ToString());
			Console.WriteLine(daveTicket.ToString());
			Console.WriteLine("----------------------------------------");
			Assert.AreEqual(Status.Notified, bobTicket.Status);
			Assert.AreEqual(Status.New, daveTicket.Status);

			Thread.Sleep(3000);
			Console.WriteLine("----------------------------------------");
			Console.WriteLine("    POST FIRE 1st SLEEP");
			Console.WriteLine("----------------------------------------");
			Console.WriteLine(bobTicket.ToString());
			Console.WriteLine(daveTicket.ToString());
			Console.WriteLine("----------------------------------------");
			Assert.AreEqual(Status.Notified, bobTicket.Status);
			Assert.AreEqual(Status.Notified, daveTicket.Status);

			Thread.Sleep(3000);
			Console.WriteLine("----------------------------------------");
			Console.WriteLine("    POST SLEEP 2nd SLEEP");
			Console.WriteLine("----------------------------------------");
			Console.WriteLine(bobTicket.ToString());
			Console.WriteLine(daveTicket.ToString());
			Console.WriteLine("----------------------------------------");
			Assert.AreEqual(Status.Completed, bobTicket.Status);
			Assert.AreEqual(Status.Completed, daveTicket.Status);
		}
	}
}