using System;
using System.Data;
using System.Deployment.Application;
using System.Diagnostics;
using System.IO;
using System.Runtime.CompilerServices;
using System.Runtime.InteropServices;
using System.ServiceProcess;
using System.Xml;
using Microsoft.VisualBasic;
using Microsoft.VisualBasic.CompilerServices;
using static iMESCore.Base.iMESConst;
using static iMESCore.Base.iMESComXML;
using static iMESCore.Base.iMESComSubroutine;

namespace AutoRunService
{

    public partial class AutoRunService : ServiceBase
    {

        // 2016/06/23 YF, 改呼叫wsInvoke

        private string tblJobQueue, tblJob;
        private int intMaxRunningJobCount = modAutoRun.gIntMaxRunningJobCount;

        // 2017/12/26 OwenLiu, mantis:0043439, AutoRunService 問題調整
        // 2014/06/25 YF, 記錄JOB的執行狀況
        private Collection CollectionJob = new Collection();

        // 取回JOB LIST 到 JOB QUEUE的時間間隔(單位:秒)  '20211015 13871,修正為*1000才是秒
        private int MonitorjoblistDuration = (int)Math.Round(Conversions.ToDouble(modWIN.GetAppSettings("MonitorjoblistDuration")) * 1000d);
        // 到JOB QUEUE 檢查是否有要執行的job的時間間隔(單位:秒) '20211015 13871,修正為*1000才是秒
        private int MonitorQueueDuration = (int)Math.Round(Conversions.ToDouble(modWIN.GetAppSettings("MonitorQueueDuration")) * 1000d);

        public AutoRunService()
        {
            InitializeComponent();
        }

        protected override void OnStart(string[] args)
        {

            var currentDomain = AppDomain.CurrentDomain;
            currentDomain.UnhandledException += CurrentDomain_UnhandledException;

            // 在此加入啟動服務的程式碼。這個方法必須設定已啟動的
            // 事項，否則可能導致服務無法工作。
              funWriteTxtFile("Service Starting.");

            // 2012/10/05, Aaron, 啟動時先刪除資料庫中上次執行的殘留JobQueue
            funDelMesAutoRunQueue();

            // 啟動時先載入Job List及Table架構
            funLoadAutoRunJob_All();

            // 每隔n秒鐘, 取回一次JOB LIST 到 JOB QUEUE
            TimerCheckJobList.Interval = MonitorjoblistDuration;
            TimerCheckJobList.Enabled = true;

            // 每隔n秒鐘,到 JOB QUEUE 檢查是否有要執行的
            TimerCheckQueue.Interval = MonitorQueueDuration;
            TimerCheckQueue.Enabled = true;

            modAutoRun.gIntCurrentJobCount = 0;

            funWriteTxtFile("Service Started.");

        }

        protected override void OnStop()
        {
            // 在此加入停止服務所需執行的終止程式碼。
            modAutoRun.dsJob.Dispose();
            modAutoRun.dsJobQueue.Dispose();
            TimerCheckJobList.Enabled = false;
            TimerCheckQueue.Enabled = false;
            funWriteTxtFile("Service Stopped.");
        }


        /// <summary>
    /// 取出近期的Job放入JobQueue中,
    /// </summary>
    /// <param name="sender"></param>
    /// <param name="e"></param>
    /// <remarks></remarks>
        private void TimerCheckJobList_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
        {

            // funWriteTxtFile("Running CheckJobList...")

            TimerCheckJobList.Enabled = false;

            // *****取回最近要執行的Jobs, 放入JobQueue中
            funGetJob2Queue();

            // *****平分近8分的工作
            TimerCheckJobList.Enabled = true;

        }


        /// <summary>
    /// 定期檢查JobQueue是否有工作預定執行之動作,
    /// </summary>
    /// <param name="sender"></param>
    /// <param name="e"></param>
    /// <remarks></remarks>
        private void TimerCheckQueue_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
        {

            // funWriteTxtFile("Running CheckQueue...")

            // 若未達到最大同時執行工作數目之限制時
            if (modAutoRun.gIntCurrentJobCount < intMaxRunningJobCount)
            {
                TimerCheckQueue.Enabled = false;

                do
                {
                    try
                    {

                        int intTmp;
                        var strJOB = new string[3];
                        DateTime dateTmp;
                        int intTmp2;
                        string strServerName;

                        // *****從JobQueue中取回資料,存成 DataSet
                        funReBind();

                        // 2017/12/26 OwenLiu, mantis:0043439, AutoRunService 問題調整
                        // 2014/06/25 YF, JobQueue物件不存在則跳離
                        if (modAutoRun.dsJobQueue.Tables[tblJobQueue] == null)
                        {
                            break;
                        }

                        // 2014/06/25 YF, 將tblJobQueue內Running的Job與CollectionJob做比對, 來判斷Job是否已死在Queue內
                        // CollectionJob內若還有此JobNo, 則表示該Job還在執行中, 若沒有則表示Job已死
                        CheckJobIsDead();


                        // '*****檢查是否有需要執行的job, 包含沒有設定ServiceStation或ServiceStation為ME的Job
                        DataRow[] dr = modAutoRun.dsJobQueue.Tables[tblJobQueue].Select("(ServerName is null Or ServerName='' Or ServerName='" + System.Windows.Forms.SystemInformation.ComputerName.ToString().ToUpper() + "') and STATUS='Standby'");


                        // 如果有則處理它們
                        var loopTo = dr.Length - 1;
                        for (intTmp = 0; intTmp <= loopTo; intTmp++)
                        {
                            // 若未達到最大同時執行工作數目之限制時
                            if (modAutoRun.gIntCurrentJobCount < intMaxRunningJobCount)
                            {
                                dateTmp = Conversions.ToDate(dr[intTmp][2]);

                                // ..........判斷此job是否執行時間到
                                if (dateTmp <= DateTime.Now)
                                {
                                    strJOB[0] = Conversions.ToString(dr[intTmp][0]);
                                    strJOB[1] = Conversions.ToString(dr[intTmp][5]);

                                    // ..............再檢查一次,判斷此job是否尚未有人執行
                                    strServerName = funLoadAutoRunServerName(strJOB[0]);
                                    if ((strServerName ?? "") != defString)
                                    {
                                        if (string.IsNullOrEmpty(strServerName) || string.IsNullOrEmpty(strServerName.Trim()))
                                        {
                                            intTmp2 = 1; // 尚未有主機登記要執行
                                        }
                                        else if ((strServerName ?? "") == (System.Windows.Forms.SystemInformation.ComputerName ?? ""))
                                        {
                                            intTmp2 = 1; // 本主機自行登記要執行
                                        }
                                        else
                                        {
                                            intTmp2 = 0;
                                        } // 已經有其他機器登記要執行

                                        // 尚未有主機登記要執行或本主機自行登記要執行
                                        if (intTmp2 == 1)
                                        {

                                            // 寫入註明自己正要執行
                                            funUpdateAutoRunQueue(System.Windows.Forms.SystemInformation.ComputerName, strJOB[0], defString);

                                            // ..........再取一次,判斷ServerName是否為自己
                                            strServerName = funLoadAutoRunServerName(strJOB[0]);
                                            if ((strServerName ?? "") != defString)
                                            {
                                                if ((strServerName ?? "") == (System.Windows.Forms.SystemInformation.ComputerName ?? ""))
                                                {
                                                    modAutoRun.gIntCurrentJobCount = modAutoRun.gIntCurrentJobCount + 1;

                                                    // 建立傳入執行緒之參數物件
                                                    var objJobData = new modAutoRun.SomeStateType();
                                                    objJobData.SomeState(strJOB[0], strJOB[1]);
                                                    // 開始執行
                                                    if (System.Threading.ThreadPool.QueueUserWorkItem(new System.Threading.WaitCallback(funProcessJob), objJobData) == false)
                                                    {
                                                        // MsgBox("Thread fail.")
                                                    }

                                                }
                                            } // ...........If DataReader.Read Then

                                        } // .............If intTmp2 = 1 Then

                                    } // ...............判斷是否尚未有人執行 If DataReader.Read Then

                                } // .........判斷是否執行時間到 If dateTmp <= Now Then

                            } // ...........If gIntCurrentJobCount <= intMaxRunningJobCount Then

                        }
                    }

                    catch (Exception e1)
                    {
                        funWriteTxtFile("TimerCheckQueue Error : " + e1.Message);
                        funWriteToAnEventLog("TimerCheckQueue Error : " + e1.Message, EventLogEntryType.Error, 9000);
                    }
                    finally
                    {
                    }
                }

                while (false);
                TimerCheckQueue.Enabled = true;
            }

            // 'Call funReBind()

        }


        /// <summary>
    /// 將執行的Log紀錄在文字檔(AutoRunWS_Log.txt)中
    /// </summary>
    /// <param name="WriteTxt"></param>
    /// <returns></returns>
    /// <remarks></remarks>
        private int funWriteTxtFile(string WriteTxt)
        {
            int funWriteTxtFileRet = default(int);

            funWriteTxtFileRet = -1;

            try
            {
                if (!Directory.Exists(AppDomain.CurrentDomain.BaseDirectory + @"\Log"))
                {
                    Directory.CreateDirectory(AppDomain.CurrentDomain.BaseDirectory + @"\Log");
                }

                var fs = new FileStream(AppDomain.CurrentDomain.BaseDirectory + @"\Log\AutoRunWS_Log_" + Strings.Format(DateTime.Now, "yyyyMMdd") + ".txt", FileMode.OpenOrCreate, FileAccess.ReadWrite);
                var w = new StreamWriter(fs);

                w.BaseStream.Seek(0L, SeekOrigin.End);
                w.WriteLine(Strings.Format(DateTime.Now, "yyyy/MM/dd HH:mm:ss") + "  " + WriteTxt);
                w.Close();
                fs.Close();

                funWriteTxtFileRet = 0;
            }

            catch (Exception e1)
            {

            }

            return funWriteTxtFileRet;

        }

        private void funWriteToAnEventLog(string sEvent, EventLogEntryType sEventType = EventLogEntryType.Information, int sEventID = 0)
        {
            string sSource = "MES AutoRun Service";
            string sLog = "Application";

            try
            {
                if (!EventLog.SourceExists(sSource))
                    EventLog.CreateEventSource(sSource, sLog);
                EventLog.WriteEntry(sSource, sEvent, sEventType, sEventID);
            }
            catch (Exception ex)
            {

            }

        }

        /// <summary>
    /// 重新載入JobQueue資料
    /// </summary>
    /// <returns></returns>
    /// <remarks></remarks>
        private int funReBind()
        {

            // //Web Service相關變數
            var XmlDoc = new XmlDocument();
            StringReader tmpStringReader;
            string InXml, OutXml, strIdentity, strParameter, XmlData, XmlSchema;

            // 先判斷是否dataset中已有equipmenttype之datatable,若有,需先remove否則會有錯誤
            if (!(modAutoRun.dsJobQueue.Tables[tblJobQueue] == null))
            {
                modAutoRun.dsJobQueue.Tables.Remove(tblJobQueue);
            }

            // 組InXml的字串
            string argSendTime = Conversions.ToString(DateTime.Now);
            strIdentity = CombineXMLIdentity(modWIN.gComputerName, modWIN.gUserNo, argSendTime);
            strParameter = "";
            InXml = CombineXMLRequest(strIdentity, strParameter);

            try
            {
                // OutXml = wsAUT.LoadMesAutoRunQueue(InXml)
                OutXml = modAutoRun.InvokeSrv("wsAUT.LoadMesAutoRunQueue", InXml);

                XmlDoc = new XmlDocument();
                // 利用XmlDoc物件處理ReturnValue 
                XmlDoc.LoadXml(OutXml);
                if (chkExecutionSuccess(XmlDoc))
                {
                    tblJobQueue = XmlDoc.GetElementsByTagName("returnvalue").Item(0).SelectNodes("loadmesautorunqueue").Item(0).SelectNodes("name").Item(0).InnerXml;

                    // 取出Schema,dataset讀取Schema可防止Null Field及DateTime的問題
                    XmlSchema = XmlDoc.DocumentElement.GetElementsByTagName("loadmesautorunqueue").Item(0).SelectNodes("schema").Item(0).InnerXml;
                    if (!string.IsNullOrEmpty(XmlSchema))
                    {
                        // 將XML讀入String Reader object中,因為Dataset讀入XML時必須透過String Reader物件
                        tmpStringReader = new StringReader(XmlSchema);
                        modAutoRun.dsJobQueue.ReadXmlSchema(tmpStringReader);
                        tmpStringReader.Close();
                    }

                    // 取出Data
                    XmlData = XmlDoc.DocumentElement.GetElementsByTagName("loadmesautorunqueue").Item(0).SelectNodes("value").Item(0).InnerXml;
                    if (!string.IsNullOrEmpty(XmlData))
                    {
                        tmpStringReader = new StringReader(XmlData);
                        modAutoRun.dsJobQueue.ReadXml(tmpStringReader);
                        tmpStringReader.Close();
                    }
                }

                else
                {
                    throw new Exception(GetExceptionSysMsg(XmlDoc) + '\r' + GetExceptionMesMsg(XmlDoc));
                }
            }

            catch (Exception e1)
            {
                funWriteTxtFile("funReBind Error : " + e1.Message);
                funWriteToAnEventLog("funReBind Error : " + e1.Message, EventLogEntryType.Error, 9000);
            }

            return default(int);

        }


        /// <summary>
    /// 取出近期的Job放入JobQueue中
    /// </summary>
    /// <remarks></remarks>
        public void funGetJob2Queue()
        {

            // //Web Service相關變數
            var XmlDoc = new XmlDocument();
            string InXml, OutXml, strIdentity, strParameter;

            // 組InXml的字串
            string argSendTime = Conversions.ToString(DateTime.Now);
            strIdentity = CombineXMLIdentity(modWIN.gComputerName, modWIN.gUserNo, argSendTime);
            strParameter = "";
            InXml = CombineXMLRequest(strIdentity, strParameter);

            try
            {
                // OutXml = wsAUT.GetJob2Queue(InXml)
                OutXml = modAutoRun.InvokeSrv("wsAUT.GetJob2Queue", InXml);

                // 利用XmlDoc物件處理ReturnValue 
                XmlDoc.LoadXml(OutXml);
                if (!chkExecutionSuccess(XmlDoc))
                {
                    throw new Exception(GetExceptionSysMsg(XmlDoc) + '\r' + GetExceptionMesMsg(XmlDoc));
                }
            }

            catch (Exception e1)
            {
                funWriteTxtFile("funGetJob2Queue Error : " + e1.Message);
                funWriteToAnEventLog("funGetJob2Queue Error : " + e1.Message, EventLogEntryType.Error, 9000);
            }

        }


        /// <summary>
    /// 取出ServerName
    /// </summary>
    /// <param name="JOBNO"></param>
    /// <returns></returns>
    /// <remarks></remarks>
        private string funLoadAutoRunServerName(string JobNo)
        {
            string funLoadAutoRunServerNameRet = default(string);
            // 判斷此job是否尚未有人執行
            // 判斷ServerName是否為自己(本機)

            funLoadAutoRunServerNameRet = defString;

            // //Web Service相關變數
            var XmlDoc = new XmlDocument();
            string InXml, OutXml, strIdentity, strParameter;

            // 組InXml的字串
            strParameter = "";
            string argSendTime = Conversions.ToString(DateTime.Now);
            strIdentity = CombineXMLIdentity(modWIN.gComputerName, modWIN.gUserNo, argSendTime);
            string argvalue_name = "jobno";
            string argname = "JobNo";
            string argtype = "String";
            string argdesc = "";
            strParameter = CombineXMLParameter(argvalue_name, argname, argtype, JobNo, argdesc);
            InXml = CombineXMLRequest(strIdentity, strParameter);

            try
            {
                // OutXml = wsAUT.LoadMesAutoRunQueue(InXml)
                OutXml = modAutoRun.InvokeSrv("wsAUT.LoadMesAutoRunQueue", InXml);

                XmlDoc.LoadXml(OutXml);
                if (chkExecutionSuccess(XmlDoc))
                {
                    // 取出CPN
                    if (XmlDoc.GetElementsByTagName("ServerName".ToUpper()).Count > 0)
                    {
                        string serverNameTmp = XmlDoc.GetElementsByTagName("ServerName".ToUpper()).Item(0).InnerXml.ToString();
                        funLoadAutoRunServerNameRet = CUnInput(serverNameTmp);
                    }
                    else
                    {
                        funLoadAutoRunServerNameRet = "";
                    }
                }
                else
                {
                    throw new Exception(GetExceptionSysMsg(XmlDoc) + '\r' + GetExceptionMesMsg(XmlDoc));
                }

                XmlDoc = null;
            }

            catch (Exception e1)
            {
                funWriteTxtFile("funLoadAutoRunServerName (JobNo : " + JobNo + ") Error : " + e1.Message);
                funWriteToAnEventLog("funLoadAutoRunServerName (JobNo : " + JobNo + ") Error : " + e1.Message, EventLogEntryType.Error, 9000);
            }

            return funLoadAutoRunServerNameRet;

        }

        private int funUpdateAutoRunQueue(string ServerName, string JobNo, string Status)
        {
            int funUpdateAutoRunQueueRet = default(int);

            // 寫入註明自己(本機)正要執行
            funUpdateAutoRunQueueRet = -1;

            // //Web Service相關變數
            var XmlDoc = new XmlDocument();
            string InXml, OutXml, strIdentity, strParameter;

            try
            {

                // 將傳入參數組成XML字串
                // 定義Identity
                string argSendTime = Conversions.ToString(DateTime.Now);
                strIdentity = CombineXMLIdentity(modWIN.gComputerName, modWIN.gUserNo, argSendTime);

                // 定義Parameter
                strParameter = string.Empty;
                strParameter = "";
                if ((ServerName ?? "") != defString)
                {
                    string argvalue_name = "servername";
                    string argname = "ServerName";
                    string argtype = "String";
                    string argdesc = "";
                    strParameter += CombineXMLParameter(argvalue_name, argname, argtype, ServerName, argdesc);
                }
                if ((JobNo ?? "") != defString)
                {
                    string argvalue_name1 = "jobno";
                    string argname1 = "JobNo";
                    string argtype1 = "String";
                    string argdesc1 = "";
                    strParameter += CombineXMLParameter(argvalue_name1, argname1, argtype1, JobNo, argdesc1);
                }
                if ((Status ?? "") != defString)
                {
                    string argvalue_name2 = "status";
                    string argname2 = "Status";
                    string argtype2 = "String";
                    string argdesc2 = "";
                    strParameter += CombineXMLParameter(argvalue_name2, argname2, argtype2, Status, argdesc2);
                }

                // request XML字串
                InXml = CombineXMLRequest(strIdentity, strParameter);

                // OutXml = wsAUT.EditMesAutoRunQueue(InXml)
                OutXml = modAutoRun.InvokeSrv("wsAUT.EditMesAutoRunQueue", InXml);

                XmlDoc.LoadXml(OutXml);
                if (!chkExecutionSuccess(XmlDoc))
                {
                    throw new Exception(GetExceptionSysMsg(XmlDoc) + '\r' + GetExceptionMesMsg(XmlDoc));
                }

                funUpdateAutoRunQueueRet = 0;
            }

            catch (Exception e1)
            {
                // Throw New Exception("Unexpected Error. Update  auto-run queue fails. " & e1.Message)
                funWriteTxtFile("funUpdateAutoRunQueue (JobNo : " + JobNo + ") Error : " + e1.Message);
                funWriteToAnEventLog("funUpdateAutoRunQueue (JobNo : " + JobNo + ") Error : " + e1.Message, EventLogEntryType.Error, 9000);
            }

            return funUpdateAutoRunQueueRet;

        }

        /// <summary>
    /// 取出Job參數設定
    /// </summary>
    /// <returns></returns>
    /// <remarks>
    /// 2016/04/26 YF, 此Function的目的在取出要執行的JOB的參數, 故不要使用dsJob物件, 以避免各執行緒異動dsJob, 而造成 "DataTable 内部索引已损坏" 的錯誤
    /// </remarks>
        private int funLoadAutoRunJob(string JobNo, ref Collection colParameters)
        {

            // Dim dr As DataRow
            // //Web Service相關變數
            var XmlDoc = new XmlDocument();
            StringReader tmpStringReader;
            string InXml, OutXml, strIdentity, strParameter, XmlData, XmlSchema;

            // 先判斷是否dataset中已有datatable,若有,需先remove否則會有錯誤
            // If Not IsNothing(dsJobQueue.Tables(tblJob)) Then
            // dsJobQueue.Tables.Remove(tblJob)
            // End If

            // 組InXml的字串
            strParameter = "";
            string argSendTime = Conversions.ToString(DateTime.Now);
            strIdentity = CombineXMLIdentity(modWIN.gComputerName, modWIN.gUserNo, argSendTime);
            string argvalue_name = "jobno";
            string argname = "JobNo";
            string argtype = "String";
            string argdesc = "";
            strParameter = CombineXMLParameter(argvalue_name, argname, argtype, JobNo, argdesc);
            InXml = CombineXMLRequest(strIdentity, strParameter);

            try
            {
                // OutXml = wsAUT.LoadMesAutoRunJob(InXml)
                OutXml = modAutoRun.InvokeSrv("wsAUT.LoadMesAutoRunJob", InXml);

                // 利用XmlDoc物件處理ReturnValue 
                XmlDoc.LoadXml(OutXml);

                if (chkExecutionSuccess(XmlDoc))
                {
                    // 2017/12/26 OwenLiu, mantis:0043439, AutoRunService 問題調整
                    tblJob = XmlDoc.GetElementsByTagName("returnvalue").Item(0).SelectNodes("loadmesautorunjob").Item(0).SelectNodes("name").Item(0).InnerXml;

                    // 2017/12/26 OwenLiu, mantis:0043439, AutoRunService 問題調整
                    lock (this)
                    {
                        if (modAutoRun.dsJob.Tables[tblJob] == null)
                        {
                            // 取出Schema,dataset讀取Schema可防止Null Field及DateTime的問題
                            XmlSchema = XmlDoc.DocumentElement.GetElementsByTagName("loadmesautorunjob").Item(0).SelectNodes("schema").Item(0).InnerXml;
                            if (!string.IsNullOrEmpty(XmlSchema))
                            {
                                // 將XML讀入String Reader object中,因為Dataset讀入XML時必須透過String Reader物件
                                tmpStringReader = new StringReader(XmlSchema);
                                modAutoRun.dsJob.ReadXmlSchema(tmpStringReader);
                                tmpStringReader.Close();
                            }
                        }

                        // 先刪除舊資料
                        DataRow[] drSel;
                        drSel = modAutoRun.dsJob.Tables[tblJob].Select("JobNo = '" + JobNo + "'");
                        if (drSel.Length > 0)
                            drSel[0].Delete();

                        // 取出Data
                        XmlData = XmlDoc.DocumentElement.GetElementsByTagName("loadmesautorunjob").Item(0).SelectNodes("value").Item(0).InnerXml;
                        if (!string.IsNullOrEmpty(XmlData))
                        {
                            tmpStringReader = new StringReader(XmlData);
                            modAutoRun.dsJob.ReadXml(tmpStringReader);
                            tmpStringReader.Close();
                        }

                        drSel = modAutoRun.dsJob.Tables[tblJob].Select("JobNo = '" + JobNo + "'");
                        if (drSel.Length > 0)
                        {
                            colParameters.Add(drSel[0]["Parameter01"].ToString(), "Parameter01");
                            colParameters.Add(drSel[0]["Parameter02"].ToString(), "Parameter02");
                            colParameters.Add(drSel[0]["Parameter03"].ToString(), "Parameter03");
                            colParameters.Add(drSel[0]["Parameter04"].ToString(), "Parameter04");
                            colParameters.Add(drSel[0]["Parameter05"].ToString(), "Parameter05");
                            colParameters.Add(drSel[0]["Parameter06"].ToString(), "Parameter06");
                            colParameters.Add(drSel[0]["Parameter07"].ToString(), "Parameter07");
                            colParameters.Add(drSel[0]["Parameter08"].ToString(), "Parameter08");
                            colParameters.Add(drSel[0]["Parameter09"].ToString(), "Parameter09");
                            colParameters.Add(drSel[0]["Parameter10"].ToString(), "Parameter10");
                            colParameters.Add(drSel[0]["EmailAddress"].ToString(), "EmailAddress");
                        }

                    }
                }

                else
                {
                    throw new Exception(GetExceptionSysMsg(XmlDoc) + '\r' + GetExceptionMesMsg(XmlDoc));
                }
            }

            catch (Exception e1)
            {
                funWriteTxtFile("funLoadAutoRunJob (JobNo : " + JobNo + ") Error : " + e1.Message);
                funWriteToAnEventLog("funLoadAutoRunJob (JobNo : " + JobNo + ") Error : " + e1.Message, EventLogEntryType.Error, 9000);
            }

            return default(int);

        }

        private void funLoadAutoRunJob_All()
        {

            // Dim dr As DataRow
            // //Web Service相關變數
            var XmlDoc = new XmlDocument();
            StringReader tmpStringReader;
            string InXml, OutXml, strIdentity, strParameter, XmlData, XmlSchema;

            // 先判斷是否dataset中已有datatable,若有,需先remove否則會有錯誤
            if (!(modAutoRun.dsJob.Tables[tblJob] == null))
            {
                modAutoRun.dsJob.Tables.Remove(tblJob);
            }

            // 組InXml的字串
            string argSendTime = Conversions.ToString(DateTime.Now);
            strIdentity = CombineXMLIdentity(modWIN.gComputerName, modWIN.gUserNo, argSendTime);
            strParameter = "";
            InXml = CombineXMLRequest(strIdentity, strParameter);

            try
            {
                // OutXml = wsAUT.LoadMesAutoRunJob(InXml)
                OutXml = modAutoRun.InvokeSrv("wsAUT.LoadMesAutoRunJob", InXml);

                // 利用XmlDoc物件處理ReturnValue 
                XmlDoc.LoadXml(OutXml);
                if (chkExecutionSuccess(XmlDoc))
                {
                    tblJob = XmlDoc.GetElementsByTagName("returnvalue").Item(0).SelectNodes("loadmesautorunjob").Item(0).SelectNodes("name").Item(0).InnerXml;

                    // 取出Schema,dataset讀取Schema可防止Null Field及DateTime的問題
                    XmlSchema = XmlDoc.DocumentElement.GetElementsByTagName("loadmesautorunjob").Item(0).SelectNodes("schema").Item(0).InnerXml;
                    if (!string.IsNullOrEmpty(XmlSchema))
                    {
                        // 將XML讀入String Reader object中,因為Dataset讀入XML時必須透過String Reader物件
                        tmpStringReader = new StringReader(XmlSchema);
                        modAutoRun.dsJob.ReadXmlSchema(tmpStringReader);
                        tmpStringReader.Close();
                    }
                    // 取出Data
                    XmlData = XmlDoc.DocumentElement.GetElementsByTagName("loadmesautorunjob").Item(0).SelectNodes("value").Item(0).InnerXml;
                    if (!string.IsNullOrEmpty(XmlData))
                    {
                        tmpStringReader = new StringReader(XmlData);
                        modAutoRun.dsJob.ReadXml(tmpStringReader);
                        tmpStringReader.Close();
                    }
                }

                else
                {
                    throw new Exception(GetExceptionSysMsg(XmlDoc) + '\r' + GetExceptionMesMsg(XmlDoc));
                }
            }

            catch (Exception e1)
            {
                funWriteTxtFile("funLoadAutoRunJob_All Error : " + e1.Message);
                funWriteToAnEventLog("funLoadAutoRunJob_All Error : " + e1.Message, EventLogEntryType.Error, 9000);
            }

        }


        /// <summary>
    /// 執行設定的Job
    /// </summary>
    /// <param name="State"></param>
    /// <remarks></remarks>
        public void funProcessJob(object State)
        {

            modAutoRun.SomeStateType strJob = (modAutoRun.SomeStateType)State;
            string strJobNo = strJob.strJobNo;
            string strJobName = strJob.strCommandName;
            var StartTime = DateTime.Now;
            string strStatus = "Fail"; // 回傳狀況先設定為Fail
            string strReturnMsg = "";
            string strMemo = "";
            string errorCode = "0000-999999";

            try
            {

                funWriteTxtFile("JobNo : " + strJobNo + ", Running.");

                // 2017/12/26 OwenLiu, mantis:0043439, AutoRunService 問題調整
                // 2014/06/25 YF, Job Running
                if (CollectionJob.Contains(strJobNo))
                {
                    CollectionJob.Remove(strJobNo);
                }
                CollectionJob.Add(1, strJobNo);

                // 1. 註明正在執行
                funUpdateAutoRunQueue(defString, strJobNo, "Running");

                // 2. 取出tblMESAutoRunJob的參數(Parameter1~Parameter5)
                var colParameters = new Collection();
                colParameters.Add(strJobNo, "JobNo");
                funLoadAutoRunJob(strJobNo, ref colParameters);

                // 3. 引用AutoRunLib.dll, 不加入參考 ----
                string strAppBase = AppDomain.CurrentDomain.BaseDirectory;
                string strFilePath;

                // 判斷是否是使用ClickOnce
                if (ApplicationDeployment.IsNetworkDeployed)
                {
                    // ClickOnce架構下將strAppBase改指回Smart Client
                    var tempUri = ApplicationDeployment.CurrentDeployment.UpdateLocation;
                    strAppBase = tempUri.ToString().Replace("/ClickOnce/MESSeries.application", "");
                }

                if (Strings.Mid(strAppBase, 1, 4) == "http")
                {
                    strFilePath = strAppBase + "/AutoRunLib.dll";
                }
                else
                {
                    strFilePath = strAppBase + "AutoRunLib.dll";
                }

                // 本機執行:將DLL放在執行檔編譯後的位置底下
                var mainAssembly = System.Reflection.Assembly.LoadFrom(strFilePath);
                // 建立Type物件
                var hashType = mainAssembly.GetType("AutoRunLib.clsAutoRunLibrary");
                // 使用ConstructorInfo建立物件
                Type[] argumentTypes = Type.EmptyTypes;
                var ctor = hashType.GetConstructor(argumentTypes);
                // 因AutoRunLib.clsAutoRunLibrary會叫用到iMESLicxManager.dll,所以AutoRunLib.dll和iMESLicxManager.dll要放在同一個路徑底下,且app.config要設連線字串
                var newHash = ctor.Invoke(new object[] { });
                // 使用MethodInfo.Invoke執行
                var meth = hashType.GetMethod("ExecuteFunction");

                // 執行設定的Job
                strReturnMsg = Conversions.ToString(meth.Invoke(newHash, new object[] { strJobName, colParameters }));

                // 若對應的程式回傳為success, 則本程序也回傳Success
                // If strReturnMsg = "success" Then strStatus = "Success"
                if (Strings.Mid(strReturnMsg, 1, 7).ToLower() == "success")
                {
                    strStatus = "Success"; // 2012/08/20,Even,需判斷若回傳值 =Success (第一字碼大寫時，造成 strStatus無判斷)，因此故意不回傳值
                    strReturnMsg = ""; // 成功不顯示msg
                }
                else if (Strings.Mid(strReturnMsg, 1, 5) == "fail;")  // 2013/01/14,Hank,狀態已是fail,故Msg不show
                {
                    // 取ErrorCode
                    string[] tmp = Strings.Split(strReturnMsg, ";");
                    if (tmp.Length >= 3)
                    {
                        if (tmp[1].Length == 11)
                        {
                            errorCode = tmp[1];
                        }
                    }

                    strReturnMsg = Strings.Replace(strReturnMsg, "fail;", "", 1, 1, CompareMethod.Text); // 拿掉前面的fail;
                }

                funWriteTxtFile("JobNo : " + strJobNo + ", Complete. " + strReturnMsg);
            }

            catch (Exception E2)
            {
                strMemo = "funProcessJob Error : " + E2.Message;
                funWriteTxtFile(strMemo);
                funWriteToAnEventLog(strMemo, EventLogEntryType.Error, 9000);
            }
            finally
            {
                try
                {

                    // Job完成後的後續動作:
                    // 刪除已經執行完畢之工作 (最先做, 減少執行完畢而未刪的情形)
                    // 註記最後執行時間
                    // 增加log
                    if (strStatus == "Success")
                    {
                        funEndProcessJob(strJobNo, strStatus, CInput(strReturnMsg), 
                            CInput(System.Windows.Forms.SystemInformation.ComputerName), 
                            StartTime, DateTime.Now, Convert.ToInt32(DateAndTime.DateDiff(DateInterval.Second, StartTime, DateTime.Now)), strMemo);
                    }
                    else
                    {
                        funEndProcessJob_ErrorCode(strJobNo, strStatus, CInput(strReturnMsg), 
                            CInput(System.Windows.Forms.SystemInformation.ComputerName), StartTime, DateTime.Now,
                            Convert.ToInt32(DateAndTime.DateDiff(DateInterval.Second, StartTime, DateTime.Now)), strMemo, errorCode, "AutoRun");
                    }
                }

                catch (Exception E1)
                {
                    strMemo = "funProcessJob (JobNo : " + strJobNo + ") Error : " + E1.Message;
                    funWriteTxtFile(strMemo);
                    funWriteToAnEventLog(strMemo, EventLogEntryType.Error, 9000);
                }
                finally
                {
                    modAutoRun.gIntCurrentJobCount = modAutoRun.gIntCurrentJobCount - 1;
                }

                // 2017/12/26 OwenLiu, mantis:0043439, AutoRunService 問題調整
                // 2014/06/25 YF, Job End
                if (CollectionJob.Contains(strJobNo))
                {
                    CollectionJob.Remove(strJobNo);
                }

            }

        }

        /// <summary>
    /// 執行Job完成後的後續動作
    /// </summary>
        private int funEndProcessJob(string JobNo, string Status = defString, string ReturnMsg = defString, string ServerName = defString, DateTime StartTime = default(DateTime), DateTime EndTime = default(DateTime), int RunTime = defInteger, string Memo = defString)
        {
            int funEndProcessJobRet = default(int);
            // 刪除已經執行完畢之工作 (最先做, 減少執行完畢而未刪的情形)
            // 註記最後執行時間
            // 增加log

            funEndProcessJobRet = -1;

            // //Web Service相關變數
            var XmlDoc = new XmlDocument();
            string InXml, OutXml, strIdentity, strParameter;

            try
            {

                // 將傳入參數組成XML字串
                // 定義Identity
                string argSendTime = Conversions.ToString(DateTime.Now);
                strIdentity = CombineXMLIdentity(modWIN.gComputerName, modWIN.gUserNo, argSendTime);

                // 定義Parameter
                strParameter = string.Empty;
                string argvalue_name = "jobno";
                string argname = "JobNo";
                string argtype = "String";
                string argdesc = "";
                strParameter = CombineXMLParameter(argvalue_name, argname, argtype, JobNo, argdesc);
                if ((Status ?? "") != defString)
                {
                    string argvalue_name1 = "status";
                    string argname1 = "Status";
                    string argtype1 = "String";
                    string argdesc1 = "";
                    strParameter += CombineXMLParameter(argvalue_name1, argname1, argtype1, Status, argdesc1);
                }
                if ((ReturnMsg ?? "") != defString)
                {
                    string argvalue_name2 = "returnmsg";
                    string argname2 = "ReturnMsg";
                    string argtype2 = "String";
                    string argdesc2 = "";
                    strParameter += CombineXMLParameter(argvalue_name2, argname2, argtype2, ReturnMsg, argdesc2);
                }
                if ((ServerName ?? "") != defString)
                {
                    string argvalue_name3 = "servername";
                    string argname3 = "ServerName";
                    string argtype3 = "String";
                    string argdesc3 = "";
                    strParameter += CombineXMLParameter(argvalue_name3, argname3, argtype3, ServerName, argdesc3);
                }
                if (StartTime != defDateTime)
                {
                    string argvalue_name4 = "starttime";
                    string argname4 = "StartTime";
                    string argtype4 = "DateTime";
                    string argvalue = Strings.Format(StartTime, "yyyy/MM/dd HH:mm:ss");
                    string argdesc4 = "";
                    strParameter += CombineXMLParameter(argvalue_name4, argname4, argtype4, argvalue, argdesc4);
                } // 2016-11-09, Joe, Format日期格式
                if (EndTime != defDateTime)
                {
                    string argvalue_name5 = "endtime";
                    string argname5 = "EndTime";
                    string argtype5 = "DateTime";
                    string argvalue1 = Strings.Format(EndTime, "yyyy/MM/dd HH:mm:ss");
                    string argdesc5 = "";
                    strParameter += CombineXMLParameter(argvalue_name5, argname5, argtype5, argvalue1, argdesc5);
                } // 2016-11-09, Joe, Format日期格式
                if (RunTime != defInteger)
                {
                    string argvalue_name6 = "runtime";
                    string argname6 = "RunTime";
                    string argtype6 = "Integer";
                    string argvalue2 = RunTime.ToString();
                    string argdesc6 = "";
                    strParameter += CombineXMLParameter(argvalue_name6, argname6, argtype6, argvalue2, argdesc6);
                    RunTime = Conversions.ToInteger(argvalue2);
                }
                if ((Memo ?? "") != defString)
                {
                    string argvalue_name7 = "memo";
                    string argname7 = "Memo";
                    string argtype7 = "String";
                    string argdesc7 = "";
                    strParameter += CombineXMLParameter(argvalue_name7, argname7, argtype7, Memo, argdesc7);
                }

                // request XML字串
                InXml = CombineXMLRequest(strIdentity, strParameter);

                OutXml = modAutoRun.InvokeSrv("wsAUT.funEndProcessJob", InXml);

                XmlDoc.LoadXml(OutXml);
                if (!chkExecutionSuccess(XmlDoc))
                {
                    throw new Exception(GetExceptionSysMsg(XmlDoc) + '\r' + GetExceptionMesMsg(XmlDoc));
                }

                funEndProcessJobRet = 0;
            }

            catch (Exception e1)
            {
                funWriteTxtFile("funEndProcessJob (JobNo : " + JobNo + ") Error : " + e1.Message);
                funWriteToAnEventLog("funEndProcessJob (JobNo : " + JobNo + ") Error : " + e1.Message, EventLogEntryType.Error, 9000);
            }

            return funEndProcessJobRet;

        }
        /// <summary>
    /// 執行Job完成後的後續動作
    /// </summary>
        private int funEndProcessJob_ErrorCode(string JobNo, string Status = defString, string ReturnMsg = defString, string ServerName = defString, DateTime StartTime = default(DateTime), DateTime EndTime = default(DateTime), int RunTime = defInteger, string Memo = defString, string ErrorCode = "0000-999999", string LogClass = defString)
        {
            int funEndProcessJob_ErrorCodeRet = default(int);
            // 刪除已經執行完畢之工作 (最先做, 減少執行完畢而未刪的情形)
            // 註記最後執行時間
            // 增加log

            funEndProcessJob_ErrorCodeRet = -1;

            // //Web Service相關變數
            var XmlDoc = new XmlDocument();
            string InXml, OutXml, strIdentity, strParameter;

            try
            {

                // 將傳入參數組成XML字串
                // 定義Identity
                string argSendTime = Conversions.ToString(DateTime.Now);
                strIdentity = CombineXMLIdentity(modWIN.gComputerName, modWIN.gUserNo, argSendTime);

                // 定義Parameter
                strParameter = string.Empty;
                string argvalue_name = "jobno";
                string argname = "JobNo";
                string argtype = "String";
                string argdesc = "";
                strParameter = CombineXMLParameter(argvalue_name, argname, argtype, JobNo, argdesc);
                if ((Status ?? "") != defString)
                {
                    string argvalue_name1 = "status";
                    string argname1 = "Status";
                    string argtype1 = "String";
                    string argdesc1 = "";
                    strParameter += CombineXMLParameter(argvalue_name1, argname1, argtype1, Status, argdesc1);
                }
                if ((ReturnMsg ?? "") != defString)
                {
                    string argvalue_name2 = "returnmsg";
                    string argname2 = "ReturnMsg";
                    string argtype2 = "String";
                    string argdesc2 = "";
                    strParameter += CombineXMLParameter(argvalue_name2, argname2, argtype2, ReturnMsg, argdesc2);
                }
                if ((ServerName ?? "") != defString)
                {
                    string argvalue_name3 = "servername";
                    string argname3 = "ServerName";
                    string argtype3 = "String";
                    string argdesc3 = "";
                    strParameter += CombineXMLParameter(argvalue_name3, argname3, argtype3, ServerName, argdesc3);
                }
                if (StartTime != defDateTime)
                {
                    string argvalue_name4 = "starttime";
                    string argname4 = "StartTime";
                    string argtype4 = "DateTime";
                    string argvalue = Strings.Format(StartTime, "yyyy/MM/dd HH:mm:ss");
                    string argdesc4 = "";
                    strParameter += CombineXMLParameter(argvalue_name4, argname4, argtype4, argvalue, argdesc4);
                } // 2016-11-09, Joe, Format日期格式
                if (EndTime != defDateTime)
                {
                    string argvalue_name5 = "endtime";
                    string argname5 = "EndTime";
                    string argtype5 = "DateTime";
                    string argvalue1 = Strings.Format(EndTime, "yyyy/MM/dd HH:mm:ss");
                    string argdesc5 = "";
                    strParameter += CombineXMLParameter(argvalue_name5, argname5, argtype5, argvalue1, argdesc5);
                } // 2016-11-09, Joe, Format日期格式
                if (RunTime != defInteger)
                {
                    string argvalue_name6 = "runtime";
                    string argname6 = "RunTime";
                    string argtype6 = "Integer";
                    string argvalue2 = RunTime.ToString();
                    string argdesc6 = "";
                    strParameter += CombineXMLParameter(argvalue_name6, argname6, argtype6, argvalue2, argdesc6);
                    RunTime = Conversions.ToInteger(argvalue2);
                }
                if ((Memo ?? "") != defString)
                {
                    string argvalue_name7 = "memo";
                    string argname7 = "Memo";
                    string argtype7 = "String";
                    string argdesc7 = "";
                    strParameter += CombineXMLParameter(argvalue_name7, argname7, argtype7, Memo, argdesc7);
                }
                if ((LogClass ?? "") != defString)
                {
                    string argvalue_name8 = "logclass";
                    string argname8 = "LogClass";
                    string argtype8 = "String";
                    string argdesc8 = "";
                    strParameter += CombineXMLParameter(argvalue_name8, argname8, argtype8, LogClass, argdesc8);
                }
                string argvalue_name9 = "errorcode";
                string argname9 = "ErrorCode";
                string argtype9 = "String";
                string argdesc9 = "";
                strParameter += CombineXMLParameter(argvalue_name9, argname9, argtype9, ErrorCode, argdesc9);

                // request XML字串
                InXml = CombineXMLRequest(strIdentity, strParameter);

                OutXml = modAutoRun.InvokeSrv("wsAUT.funEndProcessJob_ErrorCode", InXml);

                XmlDoc.LoadXml(OutXml);
                if (!chkExecutionSuccess(XmlDoc))
                {
                    throw new Exception(GetExceptionSysMsg(XmlDoc) + '\r' + GetExceptionMesMsg(XmlDoc));
                }

                funEndProcessJob_ErrorCodeRet = 0;
            }

            catch (Exception e1)
            {
                funWriteTxtFile("funEndProcessJob (JobNo : " + JobNo + ") Error : " + e1.Message);
                funWriteToAnEventLog("funEndProcessJob (JobNo : " + JobNo + ") Error : " + e1.Message, EventLogEntryType.Error, 9000);
            }

            return funEndProcessJob_ErrorCodeRet;

        }
        /// <summary>
    /// 啟動時先刪除資料庫中上次執行的殘留JobQueue
    /// </summary>
    /// <remarks></remarks>
        public void funDelMesAutoRunQueue()
        {

            // //Web Service相關變數
            var XmlDoc = new XmlDocument();
            string InXml, OutXml, strIdentity, strParameter;

            // 組InXml的字串
            string argSendTime = Conversions.ToString(DateTime.Now);
            strIdentity = CombineXMLIdentity(modWIN.gComputerName, modWIN.gUserNo, argSendTime);
            string argvalue_name = "servername";
            string argname = "ServerName";
            string argtype = "String";
            string argdesc = "";
            strParameter = CombineXMLParameter(argvalue_name, argname, argtype, System.Windows.Forms.SystemInformation.ComputerName.ToString().ToUpper(), argdesc);
            InXml = CombineXMLRequest(strIdentity, strParameter);

            try
            {
                // OutXml = wsAUT.DelMesAutoRunQueue(InXml)
                OutXml = modAutoRun.InvokeSrv("wsAUT.DelMesAutoRunQueue", InXml);

                // 利用XmlDoc物件處理ReturnValue 
                XmlDoc.LoadXml(OutXml);
                if (!chkExecutionSuccess(XmlDoc))
                {
                    throw new Exception(GetExceptionSysMsg(XmlDoc) + '\r' + GetExceptionMesMsg(XmlDoc));
                }
            }

            catch (Exception e1)
            {
                funWriteTxtFile("funDelMesAutoRunQueue Error : " + e1.Message);
                funWriteToAnEventLog("funDelMesAutoRunQueue Error : " + e1.Message, EventLogEntryType.Error, 9000);
            }

        }

        private void CurrentDomain_UnhandledException(object sender, UnhandledExceptionEventArgs args)
        {
            try
            {
                Exception e = (Exception)args.ExceptionObject;
                funWriteTxtFile(e.Message);
                funWriteToAnEventLog(e.Message, EventLogEntryType.Error, 9000);
            }

            catch (Exception ex)
            {

            }
        }

        // 2017/12/26 OwenLiu, mantis:0043439, AutoRunService 問題調整
        // 2014/06/25 YF, 將tblJobQueue內Running的Job與CollectionJob做比對, 來判斷Job是否已死在Queue內
        // 若CollectionJob沒有此JobNo, 則表示Job已死, 將Job狀態改為Standby, 即可再繼續執行
        private void CheckJobIsDead()
        {

            try
            {

                foreach (DataRow row in modAutoRun.dsJobQueue.Tables[tblJobQueue].Select("(ServerName is null Or ServerName='' Or ServerName='" + System.Windows.Forms.SystemInformation.ComputerName.ToString().ToUpper() + "') and STATUS='Running'"))
                {

                    if (!CollectionJob.Contains(Conversions.ToString(row["JobNo"])))
                    {
                        row["Status"] = "Standby";
                    }

                }
            }

            catch (Exception ex)
            {
                funWriteTxtFile("CheckJobIsDead Error: " + ex.Message);
                funWriteToAnEventLog(ex.Message, EventLogEntryType.Error, 9000);
            }

        }

    }
}