1        /**//// <summary>
2        /// 事件处理线程
3        /// 每间隔1s处理一次到时间了的事件
4        /// </summary>
5        static void EventThread()
6        {
7            DateTime lastTime = DateTime.Now;
8            while (Run)
9            {
10                try
11                {
12                    Event.SystemEvent.DoEvent(lastTime);
13                }
14                catch (Exception ex)
15                {
16                    Common.Logging.Error(ex.ToString());
17                }
18
19                long def = DateTime.Now.Ticks - lastTime.Ticks;
20                lastTime = DateTime.Now;
21
22                if (def < 10000000)
23                {
24                    //  线程休息，并等待下一次时间间隔
25                    int ms = (int)(10000000 - def) / 10000;
26                    if (ms > 0)
27                        System.Threading.Thread.Sleep(ms);
28                }
29            }
30        }

1  /**//// <summary>
2    /// 系统事件
3    /// 主要作用是执行处理事件的过程
4    /// </summary>
5    public class SystemEvent
6    {
7        public static void DoEvent(DateTime time)
8        {
9            List<Event> evs = Event.GetEvents(time);
10            foreach (Event e in evs)
11            {
12                try
13                {
14                    IEvent ie = e.Object;
15                    if (ie != null)
16                    {
17                        ie.Parent = e;
18                        ie.DoEvent();
19                    }
20                }
21                catch (Exception ex)
22                {
23                    Common.Logging.Error(ex.ToString(), e.EventObject);
24                }
25                try
26                {
27                    e.Delete();    // 从数据库里删除信息
28                }
29                catch (Exception ex)
30                {
31                    Common.Logging.Error(ex.ToString());
32                }
33            }
34        }
35    }
36