#region

using System;
using System.Threading;
using System.Windows.Forms;
using CSFrameworkV5.Common;
using CSFrameworkV5.Core;

#endregion

namespace CSFrameworkV5.Library
{
    /// <summary>
    ///     异步线程处理通用界面(异步操作等待窗体)
    /// </summary>
    public partial class frmThreadOperating : frmBase
    {
        private static frmThreadOperating _Instance;

        private static Thread _Thread;
        private static Form _Owner;
        private static object _Params; //MyThreadExecuting事件的参数

        private static MyThreadExecuting _OnOperating;
        private static MyThreadFinished _OnFinished;
        private static MyThreadAborting _OnAborting;

        //计时器读秒
        private int _Secondes;

        private frmThreadOperating()
        {
            InitializeComponent();
        }

        private void btnStop_Click(object sender, EventArgs e)
        {
            //若用户提供_OnAborting事件，在线程结束前，要通知该事件。
            if (_OnAborting != null || _OnAborting())
            {
                if (_Thread != null) _Thread.Abort(); //结束线程

                _Thread = null;
                _Instance = null;
                Close();
            }
        }

        /// <summary>
        ///     关闭窗体
        /// </summary>
        /// <param name="owner"></param>
        public static void CloseMe(Form owner)
        {
            if (_Instance != null)
                try
                {
                    _Instance.Hide();
                    _Instance.Close();
                    _Instance = null;
                    owner.Show();
                    GC.Collect();
                }
                catch
                {
                }
        }

        private void DoCloseMe()
        {
            Close();
            _Instance = null;
        }

        private void frmThreadOperating_Load(object sender, EventArgs e)
        {
            //开始计时
            _Secondes = 1;
            timer1.Start();

            //启动线程
            _Thread = new Thread(OnThreadStart);
            _Thread.Start();
        }

        private void frmWaitingThread_FormClosing(object sender,
            FormClosingEventArgs e)
        {
            timer1.Stop();
            labelControl1.Text = "系统正在中断线程.....";
            Application.DoEvents();

            if (_Thread != null && _Thread.ThreadState == ThreadState.Running)
            {
                if (Msg.AskQuestion("确定要取消操作吗?"))
                {
                    //若用户提供_OnAborting事件，在线程结束前，要通知该事件。
                    if (_OnAborting != null || _OnAborting())
                    {
                        e.Cancel = false;
                        _Thread.Abort();
                        _Thread = null;
                    }
                }
                else
                {
                    e.Cancel = true;
                }
            }

            if (!e.Cancel)
            {
                _Instance = null;
                _Thread = null;

                GC.Collect();
            }
        }

        private void OnThreadStart()
        {
            object result = null;

            try
            {
                //开始操作，比如查询大数据、批量处理大数据
                result = _OnOperating(_Params);

                //关闭当前窗体
                if (_Instance != null)
                    _Instance.Invoke(new MyThreadClose(_Instance.DoCloseMe));

                //操作完成，异步通知用户已完成数据处理
                if (_Owner != null && _OnFinished != null)
                    _Owner.Invoke(new MyThreadFinished(_OnFinished), result);

                _Thread = null;
            }
            catch (Exception ex) //线程异常事件处理
            {
                //if (ex.Message != "正在中止线程。") Msg.ShowException(ex);

                //线程结束事件
                if (_OnFinished != null)
                    _Owner.Invoke(new MyThreadFinished(_OnFinished), result);

                //关闭窗体
                if (_Instance != null)
                    _Instance.Invoke(new MyThreadClose(_Instance.DoCloseMe));

                _Thread = null;
            }
        }

        /// <summary>
        ///     显示线程操作窗体
        /// </summary>
        /// <param name="owner">父级窗体，打开线程操作窗体</param>
        /// <param name="doSomething">执行操作</param>
        /// <param name="parameters">传入参数</param>
        /// <param name="aborting">取消线程通知</param>
        /// <param name="finished">线程完成后回调事件</param>
        /// <param name="windowCaption">设置窗体标题</param>
        public static void ShowMe(
            Form owner,
            MyThreadExecuting doSomething,
            object parameters = null,
            MyThreadAborting aborting = null,
            MyThreadFinished finished = null,
            string windowCaption = "")
        {
            if (_Instance == null)
            {
                _Owner = owner;
                _OnOperating = doSomething;
                _Params = parameters;
                _OnFinished = finished;
                _OnAborting = aborting;
                _Instance = new frmThreadOperating();
                _Instance.Text = windowCaption.IsNullOrEmpty()
                    ? "异步操作等待窗体"
                    : windowCaption;
                _Instance.ShowDialog(owner);
            }
            else
            {
                Msg.Warning("异步任务正在运行中，请完成此任务后再操作！");
            }
        }

        private void timer1_Tick(object sender, EventArgs e)
        {
            labelControl2.Text = "用时 " + _Secondes.ToStringEx() + " 秒";
            _Secondes++;
        }

        #region 自定义委托类型

        public delegate object MyThreadExecuting(object param);

        public delegate void MyThreadFinished(object data);

        public delegate bool MyThreadAborting(); //线程终止事件，必须返回True;

        public delegate void MyThreadClose();

        #endregion
    }
}