using System;
using System.Xml;
using System.Threading;
using System.Reflection;


namespace DBEntryTest
{
    /// <summary>
    /// 排程
    /// </summary>
    public class Assignment
    {
        private XmlDocument xmlDoc;
        private delegate void myMothod(XmlNode node);
        
        public Assignment()
        {
            xmlDoc = new XmlDocument();
        }

        #region    排程Xml文件
        private String fileSource = String.Empty;
        /// <summary>
        /// 排程Xml文件
        /// </summary>
        public String FileSource
        {
            get{return fileSource;}
            set{fileSource = value;}
        }
        #endregion

        #region 啟動排程
        /// <summary>
        ///  啟動排程
        /// </summary>
        public void Run()
        {
            if(this.FileSource.Equals(String.Empty))
                throw new Exception("請指定排程Xml文件源!");
            this.xmlDoc.Load(this.FileSource);
            //獲取所有的排程信息
            XmlNodeList nodeList = xmlDoc.SelectNodes("//Assignments/Assignment");
            if(nodeList.Count > 0)
            {
                foreach(XmlNode node in nodeList)
                {
                    //每條線程執行一個排程
                    ThreadPool.QueueUserWorkItem(new WaitCallback(SingleAssignment),node);
                }
            }
        }
        #endregion

        #region 單排程

        #region 單排程啟始接口
        /// <summary>
        /// 單排程啟始接口
        /// </summary>
        /// <param name="args">排程信息</param>
        private void SingleAssignment(object args)
        {
            XmlNode node =(XmlNode)args;
            string type = node.Attributes["typeName"].Value;
            switch(type)
            {
                case "Month":
                    ListenerMonth(node);
                    break;
                case "Week":
                    ListenerWeek(node);
                    break;
                case "Day":
                    ListenerDay(node);
                    break;
                default:
                    break;
            }
        }
        #endregion

        #region 監聽月
        /// <summary>
        /// 監聽月
        /// </summary>
        /// <param name="node">排程信息</param>
        private void ListenerMonth(XmlNode node)
        {
            XmlNode subNode = node.SelectSingleNode("./Months/Month[@id=\"" + DateTime.Now.Month.ToString() + "\"]");
            if(subNode != null )
            {
                //當前月為執行月
                string type = subNode.Attributes["typeName"].Value;
                switch(type)
                {
                    case "Week":
                        ListenerWeek(node);
                        break;
                    case "Day":
                        ListenerDay(node);
                        break;
                    default:
                        throw new Exception("按月執行的類型不正確!");
                }
            }
            else
            {
                Thread.Sleep(DateTime.Now.AddMonths(1).AddDays(-DateTime.Now.Day).AddHours(-DateTime.Now.Hour).AddMinutes(-DateTime.Now.Minute) - DateTime.Now);
                ListenerMonth(node);
            }
        }
        #endregion

        #region 監聽周
        /// <summary>
        /// 監聽周
        /// </summary>
        /// <param name="node">排程信息</param>
        private void ListenerWeek(XmlNode node)
        {
            XmlNodeList nodeList = node.SelectNodes("./Weeks/Week[@id=0]");
            if(nodeList.Count > 0)
            {
                bool isToday = false;    //是否今天執行
                foreach(XmlNode dayNode in nodeList)
                {
                    if(dayNode.SelectSingleNode("./Day[@id=" + WeekValue(DateTime.Now.DayOfWeek).ToString() + "]") != null)
                    {
                        isToday = true;
                        break;
                    }
                }
                if(isToday)
                {
                    myMothod delegate1 = new myMothod(ListenerWeek);
                    ListenerHour(node,delegate1);
                }
                else
                {
                    //等待下一天
                    Thread.Sleep(DateTime.Now.AddDays(1).AddHours(-DateTime.Now.Hour).AddMinutes(-DateTime.Now.Minute) - DateTime.Now);
                    if(GetLastDateInMonth(DateTime.Now.Year,DateTime.Now.Month).Equals(DateTime.Now.Day))
                    {
                        if(node.Attributes["type"].Value.Equals("Month"))
                        {
                            ListenerMonth(node); //如為按月執行，則返回監聽月
                        }
                        else
                        {
                            ListenerWeek(node);    //繼續
                        }
                    }
                    else
                    {
                        ListenerWeek(node);    //繼續
                    }
                }
            }
        }
        #endregion

        #region 監聽天
        /// <summary>
        /// 監聽天
        /// </summary>
        /// <param name="node">排程信息</param>
        private void ListenerDay(XmlNode node)
        {
            string lastDate =  (GetLastDateInMonth(DateTime.Now.Year,DateTime.Now.Month).Equals(DateTime.Now.Day)) ? "0" : "32";
            if(node.SelectSingleNode("./Days/Day[@id=" + DateTime.Now.Day + " or @id=" + lastDate + "]") != null)
            {
                //為今天執行
                myMothod delegate1 = new myMothod(ListenerDay);
                ListenerHour(node,delegate1);
            }
            else
            {
                //等待下一天
                Thread.Sleep(DateTime.Now.AddDays(1).AddHours(-DateTime.Now.Hour).AddMinutes(-DateTime.Now.Minute) - DateTime.Now);
                if(GetLastDateInMonth(DateTime.Now.Year,DateTime.Now.Month).Equals(DateTime.Now.Day))
                {
                    if(node.Attributes["type"].Value.Equals("Month"))
                    {
                        ListenerMonth(node); //如為按月執行，則返回監聽月
                    }
                    else
                    {
                        ListenerDay(node);    //繼續
                    }
                }
                else
                {
                    ListenerDay(node);    //繼續
                }
            }
        }
        #endregion

        #region 監聽小時
        /// <summary>
        /// 監聽小時
        /// </summary>
        /// <param name="node">排程信息</param>
        private void ListenerHour(XmlNode node, myMothod delegate1)
        {
            if(node.SelectSingleNode("./Hours/Hour[@id=" + DateTime.Now.Hour.ToString() + "]") != null)
            {
                //當前小時
                ListenerMinute(node,delegate1);
            }
            else
            {
                Thread.Sleep(DateTime.Now.AddHours(1).AddMinutes(-DateTime.Now.Minute) - DateTime.Now);//等待下一小時
                if(DateTime.Now.Hour == 0)
                {
                    delegate1(node);
                }
                else
                {
                    ListenerHour(node,delegate1);
                }
            }
        }
        #endregion

        #region 監聽分鐘
        /// <summary>
        /// 監聽分鐘
        /// </summary>
        /// <param name="node">排程信息</param>
        private void  ListenerMinute(XmlNode node, myMothod delegate1)
        {
            if(node.SelectSingleNode("./Minutes/Minute[@id=" + DateTime.Now.Minute.ToString() + "]") != null)
            {
                //當前分鐘
                string execute = node.Attributes["execute"].Value;    //取得執行方法
                #region 取得排程的其它信息

                #endregion

                //執行方法可能需要較長的時間，所在采用拋出線程的方法來異步執行
                ExecuteParam executeParam = new ExecuteParam(execute,null);
                ThreadPool.QueueUserWorkItem(new WaitCallback(Execute),executeParam);
            }

            Thread.Sleep((60 - DateTime.Now.Second) * 60 );    //等待下一分鐘
            if(DateTime.Now.Minute == 0)
            {
                //返回監聽小時
                ListenerHour(node,delegate1);
            }
            else
            {
                ListenerMinute(node,delegate1);
            }
        }
        #endregion

        #endregion

        #region 執行排程操作
        /// <summary>
        /// 執行排程操作
        /// </summary>
        private void Execute(object args)
        {
            ExecuteParam exeArgs = (ExecuteParam)args;
            string exeObj = exeArgs.ExeObj;
            string className = exeObj.Substring(0,exeObj.LastIndexOf("."));
            string methodName = exeObj.Substring(exeObj.LastIndexOf(".")+1).Replace("()","");
            Type type = Type.GetType(className);
            MethodInfo method = type.GetMethod(methodName);
            method.Invoke(null,exeArgs.Argument);
        }
        #endregion

        #region 執行排程操作參數
        /// <summary>
        ///  執行排程操作參數
        /// </summary>
        private struct ExecuteParam
        {
            private string exeObj;
            private object[] argument;

            public ExecuteParam(string argument1,object[] argument2)
            {
                this.exeObj = argument1;
                this.argument = argument2;
            }

            /// <summary>
            /// 執行個體,如:EArtService.Output.OutputXml()
            /// </summary>
            public string ExeObj
            {
                get{return this.exeObj;}
            }
            /// <summary>
            /// 執行個體參數
            /// </summary>
            public object[] Argument
            {
                get{return this.argument;}
            }
        }
        #endregion


        #region 取得星期的序號
        /// <summary>
        /// 取得星期的序號
        /// </summary>
        /// <param name="week"></param>
        /// <returns></returns>
        public int WeekValue(DayOfWeek week)
        {
            int iWeek = 0;
            switch(week)
            {
                case DayOfWeek.Monday:
                    iWeek = 1;
                    break;
                case DayOfWeek.Tuesday:
                    iWeek = 2;
                    break;
                case DayOfWeek.Wednesday:
                    iWeek = 3;
                    break;
                case DayOfWeek.Thursday:
                    iWeek = 4;
                    break;
                case DayOfWeek.Friday:
                    iWeek = 5;
                    break;
                case DayOfWeek.Saturday:
                    iWeek = 6;
                    break;
                case DayOfWeek.Sunday:
                    iWeek = 7;
                    break;
                default:
                    iWeek = 0;
                    break;
            }
            return iWeek;
        }
        #endregion

        #region 取得這個月的最後一天
        /// <summary>
        /// 取得這個月的最後一天
        /// </summary>
        /// <param name="month"></param>
        /// <returns></returns>
        private int GetLastDateInMonth(int year,int month)
        {
            int reValue = 30;
            if(month==1 || month==3 || month==5 || month==7 || month==8 || month==10 || month==12)
            {
                reValue = 31;
            }
            if(month==2)
            {
                reValue = 28;
                if((year/4==0 && year/100==0) || year/400==0)
                {
                    reValue = 29;
                }
            }
            return reValue;
        }
        #endregion
        
    }
}

以上代碼就不明細說明瞭，上面的注解我想說得差不多可以理解了吧

這個排程的工作原理，有點例似於Socket的監聽吧，所以我叫它監聽排程
所用到的技術(委託，線程，反射)

 3. 工作流程圖

方案二
   因那個專案客戶還沒驗收，等驗收後再拿來羨丑了(工作原理：只是多了個按下次執行日期來算的)

 
   哪位感興趣的朋友，如了解排程算法的可以一起研究下，最好是教我：)O