/**  
* EC_DemandQuoteDAL.cs
*
* 功 能： 需求报价数据访问实现
* 类 名： EC_DemandQuoteDAL
*
* Ver    变更日期             负责人  变更内容
* ───────────────────────────────────
* V0.01  2013-4-12 9:23       吴崎均    更改InsertModel以及UpdateModel以与存储相匹配
* V0.02                       吴崎均    新增分页实现、获取单个实体实现 
* V0.03  2013-4-18 16:00      吴崎均    新增批量删除 
* V0.04  2013-5-24 10:32      吴崎均    新增根据编号获取实体
* V0.5   2013-5-28 13:43      吴崎均    修改批量删除方法定义及实现
*
*
*
*
*/
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 CY.Infrastructure.Query;

namespace CY.SQLDAL
{


    /// <summary>
    /// 需求报价数据访问实现
    /// </summary>
    public class EC_DemandQuoteDAL : IEC_DemandQuoteDAL
    {

        private Database _dataBase = null;


        #region 常量

        /// <summary>
        /// 查询目标 
        /// </summary>
        const string SELECTTARGET = @" d.*,
		                            m.Name as QuoterName,
                                    q.DemandName as DemandName ,q.EndTime
                                    ";
        /// <summary>
        /// 查询来源
        /// </summary>
        const string FROMSOUCEBEFORE = " EC_DemandQuote  as d Inner Join EC_MemberBasic as m On(d.QuoterId=m.MemberId  ";
        const string FROMSOUCEEND = " ) Inner Join EC_QuoteDemand as q On(d.DemandId=q.Keyid)";
        /// <summary>
        /// 分页默认排序字段
        /// </summary>
        const string ORDERBY = "d.Keyid desc ";
        #endregion

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

        /// <summary>
        /// 新增
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.EC_DemandQuote trueModel = model as Model.EC_DemandQuote;
            if (trueModel == null)
            {
                return false;
            }
            else { }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                new SqlParameter("@DemandId",trueModel.DemandId),
					new SqlParameter("@QuoteInfo",trueModel.QuoteInfo),
                    new SqlParameter("@QuoterId",trueModel.QuoterId),
					new SqlParameter("@QuoterPrice",trueModel.QuoterPrice),
					new SqlParameter("@QuoteRemark",trueModel.QuoteRemark)
            };
            try
            {
                _dataBase.Query("sp_EC_DemandQuote_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)
        {

            return false;
        }

        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public bool DeleteModel(Infrastructure.Domain.IAggregateRoot model)
        {
            Model.EC_DemandQuote trueModel = model as Model.EC_DemandQuote;
            if (trueModel == null)
            {
                return false;
            }
            else { }
            IList<SqlParameter> sqlParms = new List<SqlParameter>()
            {
                new SqlParameter("@Keyid",trueModel.Keyid)
            };
            try
            {
                _dataBase.Query("sp_EC_DemandQuote_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<EC_DemandQuote> SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination)
        {
            if (null == pagination || null == query || null == query.Criteria || 1 > query.Criteria.Count) return null; else { }
            //query.Criteria 首个元素必须是排序字段，其值为结果排序字段

            int maxParamIndex = query.Criteria.Count - 1;//最大索引

            string[] orderbys = new string[] { ORDERBY };
            string resultOrderBy = "";//结果集排序方式

            if ("@orderBy".Equals(query.Criteria[maxParamIndex].PropertyName))
            {
                orderbys = string.Format("{0}", query.Criteria[maxParamIndex].Value).Split(',');
                resultOrderBy = 1 == orderbys.Length ? resultOrderBy : orderbys[1];
            }

            string fromSouce = string.Format("{0}{1}{2}", FROMSOUCEBEFORE, query.Criteria[0].Value, FROMSOUCEEND);//拼装条件
            return _dataBase.SelectModelPage<EC_DemandQuote>(pagination, SELECTTARGET, fromSouce, orderbys[0], resultOrderBy);
        }

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

        /// <summary>
        /// 根据需求编号查询报价(分页)
        /// </summary>
        /// <param name="pagination">分页参数</param>
        /// <param name="demandId">需求编号</param>
        /// <param name="beginDate">开始时间</param>
        /// <param name="endDate">结束时间</param>
        /// <returns></returns>
        public IEnumerable<EC_DemandQuote> SelectModelPageByDemandId(Infrastructure.Query.Pagination pagination, int demandId, DateTime? beginDate, DateTime? endDate)
        {
            if (demandId < 1) return null;//错误数据返会空 
            else { }

            string condition = string.Format(" And d.DemandId= {0}", demandId);
            if (beginDate.HasValue) { condition += string.Format(" And d.QuoteTime >= '{0}' ", beginDate.Value); }
            else if (endDate.HasValue) { condition += string.Format(" And d.QuoteTime <= '{0}' ", endDate.Value); } else { }

            Query query = new Query(true);
            query.Criteria.Add(new Criterion("condition", condition));

            return SelectModelPage(query, pagination);
        }
        /// <summary>
        /// 根据报价人编号查询报价(分页)
        /// </summary>
        /// <param name="pagination">分页参数</param>
        /// <param name="demandId">需求编号</param>
        /// <param name="beginDate">开始时间</param>
        /// <param name="endDate">结束时间</param>
        /// <returns></returns>
        public IEnumerable<EC_DemandQuote> SelectModelPageByQuoterId(Infrastructure.Query.Pagination pagination, Guid quoterId, DateTime? beginDate, DateTime? endDate)
        {
            if (Guid.Empty == quoterId) return null;//错误数据返会空 
            else { }
            string condition = string.Format(" And d.QuoterId= '{0}' ", quoterId);
            if (beginDate.HasValue) { condition += string.Format(" And d.QuoteTime >= '{0}' ", beginDate.Value.ToString("yyyy-MM-dd")); }
            else if (endDate.HasValue) { condition += string.Format(" And d.QuoteTime <= '{0}' ", endDate.Value.ToString("yyyy-MM-dd")); } else { }
            Query query = new Query(true);
            query.Criteria.Add(new Criterion("condition", condition));

            return SelectModelPage(query, pagination);
        }
    

        /// <summary>
        /// 根据编号批量删除数据
        /// </summary>
        /// <param name="currentOperator">当前操作人</param>
        /// <param name="ids">编号集合</param>
        /// <returns></returns>
        public bool DeleteDataByIds(string currentOperator, params int[] ids)
        {
            return Database.DeleteDataByIds<EC_DemandQuote>(this, currentOperator, ids);
        }


        /// <summary>
        /// 根据编号获取实体
        /// </summary>
        /// <param name="id">报价编号</param>
        /// <returns></returns>
        public EC_DemandQuote SelectModelById(int id) 
        {
            IList<EC_DemandQuote> result = _dataBase.SelectModel<EC_DemandQuote>(SELECTTARGET, string.Format("{0}{1}{2}", FROMSOUCEBEFORE,string.Format(" And d.Keyid={0}",id), FROMSOUCEEND));
             return null==result||0==result.Count?null:result[0];
        }



    }
}