entity_gatherthread.cs

c#的多线程采集源代码

using System;
using System.Collections.Generic;
using System.Text;

namespace DataEntity
{
    public class Entity_GatherThread
    {
        public Entity_GatherThread()
        { }

        #region Model

        private int _strMgId = 0;

        private string _strMgName = string.Empty;

        private string _strPeriodId = string.Empty;

        private string _strStateId = string.Empty;

        private string _strStateName = string.Empty;

        private string _strCourseManageId = string.Empty;

        private DateTime _dtNextTime = new DateTime();

        private bool _blYesOrNo = true;

        private bool _blOneFlag = true;

        private int _PeriodGather = 0;

        private DateTime _StartTime = new DateTime();

        private DateTime _EndTime = new DateTime();

        private int _DataSourceId = 0;

        private string _DataSourceName = string.Empty;

        /// <summary>
        /// 信息编码
        /// </summary>
        public int MgId
        {
            get { return this._strMgId; }
            set { this._strMgId = value; }
        }
        /// <summary>
        /// 信息名称　
        /// </summary>
        public string MgName
        {
            get { return this._strMgName; }
            set { this._strMgName = value; }
        }
        /// <summary>
        /// 信息采集周期
        /// </summary>
        public string PeriodId
        {
            get { return this._strPeriodId; }
            set { this._strPeriodId = value; }
        }

        /// <summary>
        /// 采集状态ID
        /// </summary>
        public string StateId
        {
            get { return this._strStateId; }
            set { this._strStateId = value; }
        }
        /// <summary>
        /// 采集状态名称
        /// </summary>
        public string StateName
        {
            get { return this._strStateName; }
            set { this._strStateName = value; }
        }

        /// <summary>
        /// 采集线程Id
        /// </summary>
        public string CourseManageId
        {
            get { return this._strCourseManageId; }
            set { this._strCourseManageId = value; }
        }


        
        /// <summary>
        /// 循环采集间隔时间，单位分钟
        /// </summary>
        public int PeriodGather
        {
            get { return _PeriodGather; }
            set { _PeriodGather = value; }
        }
        /// <summary>
        /// 循环采集开始时间
        /// </summary>
        public DateTime StartTime
        {
            get { return _StartTime; }
            set { _StartTime = value; }
        }
        /// <summary>
        /// 循环采集结束时间
        /// </summary>
        public DateTime EndTime
        {
            get { return _EndTime; }
            set { _EndTime = value; }
        }


        /// <summary>
        /// 通过周期的计算，下次该信息启动进程的时间
        /// </summary>
        public DateTime NextTime
        {
            get { return _dtNextTime; }
            set { _dtNextTime = value; }
        }
        /// <summary>
        /// 当信息是按天采集时，值为true,表示当天未采集过,反之则表示当天已启动过
        /// </summary>
        public bool OneFlag
        {
            get { return _blOneFlag; }
            set { _blOneFlag = value; }
        }

        /// <summary>
        /// 判断定时采集的记录当前是否需要采集,true表示需要采集,false表示不需要采集
        /// </summary>
        public bool OneYesOrNo
        {
            get
            {
                if (OneFlag == false && DateTime.Now.Date == NextTime.Date)
                {
                    return false;
                }
                else
                {
                    return _blYesOrNo;
                }

            }
        }
        
        /// <summary>
        /// 数据源Id
        /// </summary>
        public int DataSourceId
        {
            get { return _DataSourceId; }
            set { _DataSourceId = value; }

        }
        /// <summary>
        /// 数据源名称 
        /// </summary>
        public string DataSourceName
        {
            get { return _DataSourceName; }
            set { _DataSourceName = value; }
        }

        #endregion
    }
}