yilv_new/AA/TempDbToUfida/OpenApi/BaseDataDownLoad.cs

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using cuidian.Sql;
using System.Threading.Tasks;
using cuidian.OpenApi.Utils;
using cuidian.OpenApi.Api;

namespace TempDbToUfida.OpenApi
{
    /// <summary>
    /// OpenApi方式下载基础档案基类
    /// </summary>
    public abstract class BaseDataDownLoad : BaseDownLoad
    {
        #region 变量定义
        protected DataTable _data;
        protected string _loadSql;
        #endregion

        #region 保护函数
        protected virtual void _LoadData()
        {
            _data = DbUtils.Fill(_loadSql, ConnectionUtils.Instance.GetConnection("TempDB"));
        }

        protected abstract BusinessObject _ImportData(DataRow row);
        
        #endregion

        #region 覆写函数
        protected override void _Init()
        {
            _LoadData();
        }

        protected override void _downLoad()
        {
           
            foreach (DataRow row in _data.Rows)
            {
                BusinessObject result = _ImportData(row);
                string newcode;
                _Log(result, Convert.ToInt32(row["sysid"]),out newcode);
                if (!result.IsError)
                {

                    // _Audit(result.Id);
                    _Audit(newcode);
                }
            }
        }

        protected virtual void _Audit(string id)
        { }
        
        #endregion


    }
}