using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using CY.IDAL;
using System.Data.SqlClient;
using System.Data;
using CY.Model;
using System.Transactions;
namespace CY.SQLDAL
{
    //公文管理
    public class OA_DocumentDAL : IOA_DocumentDAL
    {
        private Database _dataBase = null;

        public OA_DocumentDAL()
        {
            _dataBase = new Database();
        }

        public OA_DocumentDAL(Database dataBase)
        {
            _dataBase = dataBase;
        }

        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.OA_Document trueModel = model as Model.OA_Document;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {            	new SqlParameter("@FirmId", trueModel.FirmId) ,            
                        	new SqlParameter("@DM_PromulgatedDate", trueModel.DM_PromulgatedDate) ,            
                        	new SqlParameter("@DM_Status", trueModel.DM_Status) ,            
                        	new SqlParameter("@DM_PostingId", trueModel.DM_PostingId) ,            
                        	new SqlParameter("@DM_PostingName", trueModel.DM_PostingName) ,            
                        	new SqlParameter("@DM_PostingFirmName", trueModel.DM_PostingFirmName) ,            
                        	new SqlParameter("@DM_DocumentType", trueModel.DM_DocumentType) ,            
                        	new SqlParameter("@DM_DocumentNumber", trueModel.DM_DocumentNumber) ,            
                        	new SqlParameter("@DM_Title", trueModel.DM_Title) ,            
                        	new SqlParameter("@DM_Content", trueModel.DM_Content) ,            
                        	new SqlParameter("@DM_ThemeWords", trueModel.DM_ThemeWords) ,            
                        	new SqlParameter("@DM_CCUnit", trueModel.DM_CCUnit) ,            
                        	new SqlParameter("@DM_PrintNumber", trueModel.DM_PrintNumber) ,            
                        	new SqlParameter("@DM_Number", trueModel.DM_Number) ,            
                        	new SqlParameter("@DM_DelTime", trueModel.DM_DelTime) ,            
                        	new SqlParameter("@DM_PrintTime", trueModel.DM_PrintTime) ,            
                        	new SqlParameter("@DM_PrintStatus", trueModel.DM_PrintStatus) ,            
                        	new SqlParameter("@LastUpdateTime", trueModel.LastUpdateTime) ,            
                        	new SqlParameter("@Operator", trueModel.Operator)             
            		 };
            try
            {
                _dataBase.Query("sp_OA_Document_Insert", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 修改
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.OA_Document trueModel = model as Model.OA_Document;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {                new SqlParameter("@Keyid", trueModel.Keyid) ,            
                            new SqlParameter("@FirmId", trueModel.FirmId) ,            
                            new SqlParameter("@DM_PromulgatedDate", trueModel.DM_PromulgatedDate) ,            
                            new SqlParameter("@DM_Status", trueModel.DM_Status) ,            
                            new SqlParameter("@DM_PostingId", trueModel.DM_PostingId) ,            
                            new SqlParameter("@DM_PostingName", trueModel.DM_PostingName) ,            
                            new SqlParameter("@DM_PostingFirmName", trueModel.DM_PostingFirmName) ,            
                            new SqlParameter("@DM_DocumentType", trueModel.DM_DocumentType) ,            
                            new SqlParameter("@DM_DocumentNumber", trueModel.DM_DocumentNumber) ,            
                            new SqlParameter("@DM_Title", trueModel.DM_Title) ,            
                            new SqlParameter("@DM_Content", trueModel.DM_Content) ,            
                            new SqlParameter("@DM_ThemeWords", trueModel.DM_ThemeWords) ,            
                            new SqlParameter("@DM_CCUnit", trueModel.DM_CCUnit) ,            
                            new SqlParameter("@DM_PrintNumber", trueModel.DM_PrintNumber) ,            
                            new SqlParameter("@DM_Number", trueModel.DM_Number) ,            
                            new SqlParameter("@DM_DelTime", trueModel.DM_DelTime) ,            
                            new SqlParameter("@DM_PrintTime", trueModel.DM_PrintTime) ,            
                            new SqlParameter("@DM_PrintStatus", trueModel.DM_PrintStatus) ,            
                            new SqlParameter("@LastUpdateTime", trueModel.LastUpdateTime) ,            
                            new SqlParameter("@Operator", trueModel.Operator),
                             new SqlParameter("@Jusequanxian", trueModel.Jusequanxian),
                     };
            try
            {
                _dataBase.Query("sp_OA_Document_Update", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool DeleteModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.OA_Document trueModel = model as Model.OA_Document;
            if (trueModel == null)
            {
                return false;
            }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
                {
                	new SqlParameter("@Keyid",trueModel.Keyid)
                };
            try
            {
                _dataBase.Query("sp_OA_Document_DeleteRow", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
            }
            catch (Exception ex)
            {
                throw ex;
            }
            return true;
        }

        /// <summary>
        /// 分页查询
        /// </summary>
        /// <param name="query"></param>
        /// <param name="pagination"></param>
        /// <returns></returns>
        public IEnumerable<Model.OA_Document> SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination)
        {
            throw new NotImplementedException();
        }

        /// <summary>
        /// 单个查询
        /// </summary>
        /// <param name="query"></param>
        /// <returns></returns>
        public IEnumerable<Model.OA_Document> SelectAllModel(Infrastructure.Query.Query query)
        {
            throw new NotImplementedException();
        }

        /// <summary>
        /// 根据编号获得信息
        /// </summary>
        /// <param name="Keyid">编号</param>
        /// <returns></returns>
        public OA_Document GetModelByKeyid(int? Keyid)
        {
            try
            {
                if (Keyid == null || Keyid < 0)
                    return null;//错误数据返会空 

                IList<OA_Document> result = _dataBase.SelectModel<OA_Document>(" * ", " OA_Document ", string.Format(" Keyid='{0}'", Keyid)) as IList<OA_Document>;//执行查询

                return (null == result || result.Count == 0) ? null : result[0];//返回结果
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 分页查询
        /// </summary>
        /// <param name="pagination"></param>
        /// <returns></returns>
        public IEnumerable<Model.OA_Document> SelectModelPage(Infrastructure.Query.Pagination pagination, Guid _FirmId, DateTime? _BeginDM_PromulgatedDate, DateTime? _EndDM_PromulgatedDate, int? _DM_Status, int? _DM_PostingId, string _DM_PostingName, string _DM_PostingFirmName, string _DM_DocumentType, string _DM_DocumentNumber, string _DM_Title, string _DM_Content, string _DM_ThemeWords, string _DM_CCUnit, int? _DM_PrintNumber, int? _DM_Number, DateTime? _BeginDM_DelTime, DateTime? _EndDM_DelTime, DateTime? _BeginDM_PrintTime, DateTime? _EndDM_PrintTime, int? _DM_PrintStatus, DateTime? _BeginLastUpdateTime, DateTime? _EndLastUpdateTime, string _Operator)
        {
            try
            {
                string condition = " 1=1 ";

                if (_FirmId != Guid.Empty)
                    condition += " and FirmId = '" + _FirmId + "'";

                if (_BeginDM_PromulgatedDate.HasValue)
                    condition += string.Format(" and CAST(DM_PromulgatedDate AS DATE) >='{0}'", _BeginDM_PromulgatedDate);

                if (_EndDM_PromulgatedDate.HasValue)
                    condition += string.Format(" and CAST(DM_PromulgatedDate AS DATE) <='{0}'", _EndDM_PromulgatedDate);

                if (_DM_Status.HasValue)
                    condition += " and DM_Status = '" + _DM_Status + "'";

                if (_DM_PostingId.HasValue)
                    condition += " and DM_PostingId = '" + _DM_PostingId + "'";

                if (!string.IsNullOrEmpty(_DM_PostingName))
                    condition += " and DM_PostingName = '" + _DM_PostingName + "'";

                if (!string.IsNullOrEmpty(_DM_PostingFirmName))
                    condition += " and DM_PostingFirmName = '" + _DM_PostingFirmName + "'";

                if (!string.IsNullOrEmpty(_DM_DocumentType))
                    condition += " and DM_DocumentType = '" + _DM_DocumentType + "'";

                if (!string.IsNullOrEmpty(_DM_DocumentNumber))
                    condition += " and DM_DocumentNumber = '" + _DM_DocumentNumber + "'";

                if (!string.IsNullOrEmpty(_DM_Title))
                    condition += " and DM_Title = '" + _DM_Title + "'";

                if (!string.IsNullOrEmpty(_DM_Content))
                    condition += " and DM_Content = '" + _DM_Content + "'";

                if (!string.IsNullOrEmpty(_DM_ThemeWords))
                    condition += " and DM_ThemeWords = '" + _DM_ThemeWords + "'";

                if (!string.IsNullOrEmpty(_DM_CCUnit))
                    condition += " and DM_CCUnit = '" + _DM_CCUnit + "'";

                if (_DM_PrintNumber.HasValue)
                    condition += " and DM_PrintNumber = '" + _DM_PrintNumber + "'";

                if (_DM_Number.HasValue)
                    condition += " and DM_Number = '" + _DM_Number + "'";

                if (_BeginDM_DelTime.HasValue)
                    condition += string.Format(" and CAST(DM_DelTime AS DATE) >='{0}'", _BeginDM_DelTime);

                if (_EndDM_DelTime.HasValue)
                    condition += string.Format(" and CAST(DM_DelTime AS DATE) <='{0}'", _EndDM_DelTime);

                if (_BeginDM_PrintTime.HasValue)
                    condition += string.Format(" and CAST(DM_PrintTime AS DATE) >='{0}'", _BeginDM_PrintTime);

                if (_EndDM_PrintTime.HasValue)
                    condition += string.Format(" and CAST(DM_PrintTime AS DATE) <='{0}'", _EndDM_PrintTime);

                if (_DM_PrintStatus.HasValue)
                    condition += " and DM_PrintStatus = '" + _DM_PrintStatus + "'";

                if (_BeginLastUpdateTime.HasValue)
                    condition += string.Format(" and CAST(LastUpdateTime AS DATE) >='{0}'", _BeginLastUpdateTime);

                if (_EndLastUpdateTime.HasValue)
                    condition += string.Format(" and CAST(LastUpdateTime AS DATE) <='{0}'", _EndLastUpdateTime);

                if (!string.IsNullOrEmpty(_Operator))
                    condition += " and Operator = '" + _Operator + "'";

                return _dataBase.SelectModelPage<Model.OA_Document>(pagination, " * ", " OA_Document ", " Keyid desc", " Keyid desc ", condition);
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        /// <summary>
        /// 根据发文部门获取列表
        /// </summary>
        /// <param name="_FirmId"></param>
        /// <param name="_BeginDM_PromulgatedDate"></param>
        /// <param name="_EndDM_PromulgatedDate"></param>
        /// <param name="_DM_PostingId"></param>
        /// <returns></returns>
        public IEnumerable<Model.OA_Document> SelectModelListByPostId(Guid _FirmId, DateTime? _BeginDM_PromulgatedDate, DateTime? _EndDM_PromulgatedDate, int? _DM_PostingId)
        {
            try
            {
                string condition = " 1=1 ";

                if (_FirmId != Guid.Empty)
                    condition += " and FirmId = '" + _FirmId + "'";

                if (_BeginDM_PromulgatedDate.HasValue)
                    condition += string.Format(" and CAST(DM_PromulgatedDate AS DATE) >='{0}'", _BeginDM_PromulgatedDate);

                if (_EndDM_PromulgatedDate.HasValue)
                    condition += string.Format(" and CAST(DM_PromulgatedDate AS DATE) <='{0}'", _EndDM_PromulgatedDate);

                if (_DM_PostingId.HasValue)
                    condition += " and DM_PostingId = '" + _DM_PostingId + "'";

                condition += " order by DM_Number DESC";

                return _dataBase.SelectModel<Model.OA_Document>(" * ", " OA_Document ", condition);
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
    }
}